diff --git a/controllers/dns.go b/controllers/dns.go index 14f007d9..62a96139 100644 --- a/controllers/dns.go +++ b/controllers/dns.go @@ -224,6 +224,14 @@ func deleteDNS(w http.ResponseWriter, r *http.Request) { return } json.NewEncoder(w).Encode(entrytext + " deleted.") + dns := models.DNSUpdate{ + Action: models.DNSDeleteByName, + Name: entrytext, + } + if err := mq.PublishDNSUpdate(params["network"], dns); err != nil { + logger.Log(0, "failed to publish dns update", err.Error()) + } + } // GetDNSEntry - gets a DNS entry diff --git a/mq/publishers.go b/mq/publishers.go index a1bae082..ca335c33 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -326,6 +326,7 @@ func PublishCustomDNS(entry *models.DNSEntry) error { if err := PublishDNSUpdate(entry.Network, dns); err != nil { return err } + return nil } // function to collect and store metrics for server nodes