diff options
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
| -rw-r--r-- | middleware/kubernetes/kubernetes.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go index 7e21d5759..7f5a86649 100644 --- a/middleware/kubernetes/kubernetes.go +++ b/middleware/kubernetes/kubernetes.go @@ -7,7 +7,7 @@ import ( "time" "github.com/miekg/coredns/middleware" - "github.com/miekg/coredns/middleware/kubernetes/msg" + "github.com/miekg/coredns/middleware/etcd/msg" "github.com/miekg/coredns/middleware/kubernetes/nametemplate" "github.com/miekg/coredns/middleware/kubernetes/util" "github.com/miekg/coredns/middleware/pkg/dnsutil" @@ -22,6 +22,7 @@ import ( "k8s.io/kubernetes/pkg/labels" ) +// Kubernetes implements a middleware that connects to a Kubernetes cluster. type Kubernetes struct { Next middleware.Handler Zones []string @@ -35,6 +36,8 @@ type Kubernetes struct { Selector *labels.Selector } +// InitKubeCache initializes a new Kubernetes cache. +// TODO(miek): is this correct? func (k *Kubernetes) InitKubeCache() error { // For a custom api server or running outside a k8s cluster // set URL in env.KUBERNETES_MASTER or set endpoint in Corefile @@ -232,7 +235,7 @@ func (k *Kubernetes) getServiceRecordForIP(ip, name string) []msg.Service { const ( priority = 10 // default priority when nothing is set ttl = 300 // default ttl when nothing is set - minTtl = 60 + minTTL = 60 hostmaster = "hostmaster" k8sTimeout = 5 * time.Second ) |