From 68e09f00a41af74234793b0b9a118438fb72969c Mon Sep 17 00:00:00 2001 From: Chris O'Haver Date: Tue, 29 Jan 2019 14:15:49 -0500 Subject: skip pushing watch updates when there are no watches (#2513) --- plugin/kubernetes/watch.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) (limited to 'plugin/kubernetes') diff --git a/plugin/kubernetes/watch.go b/plugin/kubernetes/watch.go index 5c52cc4f9..4db14ad3a 100644 --- a/plugin/kubernetes/watch.go +++ b/plugin/kubernetes/watch.go @@ -96,10 +96,16 @@ func (dns *dnsControl) sendUpdates(oldObj, newObj interface{}) { switch ob := obj.(type) { case *object.Service: dns.updateModifed() + if len(dns.watched) == 0 { + return + } dns.sendServiceUpdates(ob) case *object.Endpoints: if newObj == nil || oldObj == nil { dns.updateModifed() + if len(dns.watched) == 0 { + return + } dns.sendEndpointsUpdates(ob) return } @@ -109,9 +115,15 @@ func (dns *dnsControl) sendUpdates(oldObj, newObj interface{}) { return } dns.updateModifed() + if len(dns.watched) == 0 { + return + } dns.sendEndpointsUpdates(endpointsSubsetDiffs(p, ob)) case *object.Pod: dns.updateModifed() + if len(dns.watched) == 0 { + return + } dns.sendPodUpdates(ob) default: log.Warningf("Updates for %T not supported.", ob) -- cgit v1.2.3