diff options
author | 2016-08-08 14:30:04 -0700 | |
---|---|---|
committer | 2016-08-08 14:30:04 -0700 | |
commit | c079de65b520bd7690c7ac057a38b404947f3909 (patch) | |
tree | f2c19117a64ca0e40ab187ae068d5819814492f5 /middleware/kubernetes/kubernetes.go | |
parent | 51eaefc0377597691fec1829680b3c9612068d88 (diff) | |
download | coredns-c079de65b520bd7690c7ac057a38b404947f3909.tar.gz coredns-c079de65b520bd7690c7ac057a38b404947f3909.tar.zst coredns-c079de65b520bd7690c7ac057a38b404947f3909.zip |
Adding `resyncperiod` to Corefile (#205)
* Removing old unused inline k8s API code and tests.
* Adding parsing implementation for `resyncperiod` keyword from Corefile.
* Adding tests for parsing `resyncperiod` keyword from Corefile.
8 Updating README.md and conf/k8sCorefile.
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
-rw-r--r-- | middleware/kubernetes/kubernetes.go | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go index a8d33bb7e..7c64580c1 100644 --- a/middleware/kubernetes/kubernetes.go +++ b/middleware/kubernetes/kubernetes.go @@ -20,10 +20,6 @@ import ( clientcmdapi "k8s.io/kubernetes/pkg/client/unversioned/clientcmd/api" ) -const ( - defaultResyncPeriod = 5 * time.Minute -) - type Kubernetes struct { Next middleware.Handler Zones []string @@ -37,7 +33,7 @@ type Kubernetes struct { func (g *Kubernetes) StartKubeCache() error { // For a custom api server or running outside a k8s cluster - // set URL in env.KUBERNETES_MASTER + // set URL in env.KUBERNETES_MASTER or set endpoint in Corefile loadingRules := clientcmd.NewDefaultClientConfigLoadingRules() overrides := &clientcmd.ConfigOverrides{} if len(g.APIEndpoint) > 0 { @@ -55,6 +51,7 @@ func (g *Kubernetes) StartKubeCache() error { log.Printf("[ERROR] Failed to create kubernetes notification controller: %v", err) return err } + log.Printf("[debug] Starting kubernetes middleware with k8s API resync period: %s", g.ResyncPeriod) g.APIConn = newdnsController(kubeClient, g.ResyncPeriod) go g.APIConn.Run() |