aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/controller.go
diff options
context:
space:
mode:
authorGravatar Manuel Alejandro de Brito Fontes <aledbf@gmail.com> 2017-05-25 15:08:44 -0400
committerGravatar Miek Gieben <miek@miek.nl> 2017-05-25 20:08:44 +0100
commit7c8d1b0234145817e997b6a4f9b5a6771cf16dfa (patch)
treef83703543f8f300034076e962591679b4612ed86 /middleware/kubernetes/controller.go
parent37050dc2179e0f988a5c5df2bb63ef9b83ddde2f (diff)
downloadcoredns-7c8d1b0234145817e997b6a4f9b5a6771cf16dfa.tar.gz
coredns-7c8d1b0234145817e997b6a4f9b5a6771cf16dfa.tar.zst
coredns-7c8d1b0234145817e997b6a4f9b5a6771cf16dfa.zip
Check that all the controllers are synced agains api server (#671)
Diffstat (limited to '')
-rw-r--r--middleware/kubernetes/controller.go10
1 files changed, 9 insertions, 1 deletions
diff --git a/middleware/kubernetes/controller.go b/middleware/kubernetes/controller.go
index 892f99d33..96c5c760a 100644
--- a/middleware/kubernetes/controller.go
+++ b/middleware/kubernetes/controller.go
@@ -295,7 +295,15 @@ func endpointsWatchFunc(c *kubernetes.Clientset, ns string, s *labels.Selector)
}
func (dns *dnsControl) controllersInSync() bool {
- return dns.svcController.HasSynced()
+ hs := dns.svcController.HasSynced() &&
+ dns.nsController.HasSynced() &&
+ dns.epController.HasSynced()
+
+ if dns.podController != nil {
+ hs = hs && dns.podController.HasSynced()
+ }
+
+ return hs
}
// Stop stops the controller.