From 79eec38afdbbf358a447431338b0c1241977a974 Mon Sep 17 00:00:00 2001 From: Miek Gieben Date: Sat, 22 Sep 2018 16:08:21 +0100 Subject: plugin/kubernetes: remove var namespace (#2122) * WIP: trying stuff out Signed-off-by: Miek Gieben * Fixes Signed-off-by: Miek Gieben * Revert "WIP: trying stuff out" This reverts commit a18a6ae1233d5f34c98164fd693294c36b3240b7. --- plugin/kubernetes/controller.go | 14 ++++++-------- plugin/kubernetes/kubernetes.go | 2 +- 2 files changed, 7 insertions(+), 9 deletions(-) (limited to 'plugin/kubernetes') diff --git a/plugin/kubernetes/controller.go b/plugin/kubernetes/controller.go index db231c89d..559262e26 100644 --- a/plugin/kubernetes/controller.go +++ b/plugin/kubernetes/controller.go @@ -19,8 +19,6 @@ import ( "k8s.io/apimachinery/pkg/watch" ) -var namespace = api.NamespaceAll - const ( podIPIndex = "PodIP" svcNameNamespaceIndex = "NameNamespace" @@ -114,8 +112,8 @@ func newdnsController(kubeClient *kubernetes.Clientset, opts dnsControlOpts) *dn dns.svcLister, dns.svcController = cache.NewIndexerInformer( &cache.ListWatch{ - ListFunc: serviceListFunc(dns.client, namespace, dns.selector), - WatchFunc: serviceWatchFunc(dns.client, namespace, dns.selector), + ListFunc: serviceListFunc(dns.client, api.NamespaceAll, dns.selector), + WatchFunc: serviceWatchFunc(dns.client, api.NamespaceAll, dns.selector), }, &api.Service{}, opts.resyncPeriod, @@ -125,8 +123,8 @@ func newdnsController(kubeClient *kubernetes.Clientset, opts dnsControlOpts) *dn if opts.initPodCache { dns.podLister, dns.podController = cache.NewIndexerInformer( &cache.ListWatch{ - ListFunc: podListFunc(dns.client, namespace, dns.selector), - WatchFunc: podWatchFunc(dns.client, namespace, dns.selector), + ListFunc: podListFunc(dns.client, api.NamespaceAll, dns.selector), + WatchFunc: podWatchFunc(dns.client, api.NamespaceAll, dns.selector), }, &api.Pod{}, opts.resyncPeriod, @@ -137,8 +135,8 @@ func newdnsController(kubeClient *kubernetes.Clientset, opts dnsControlOpts) *dn if opts.initEndpointsCache { dns.epLister, dns.epController = cache.NewIndexerInformer( &cache.ListWatch{ - ListFunc: endpointsListFunc(dns.client, namespace, dns.selector), - WatchFunc: endpointsWatchFunc(dns.client, namespace, dns.selector), + ListFunc: endpointsListFunc(dns.client, api.NamespaceAll, dns.selector), + WatchFunc: endpointsWatchFunc(dns.client, api.NamespaceAll, dns.selector), }, &api.Endpoints{}, opts.resyncPeriod, diff --git a/plugin/kubernetes/kubernetes.go b/plugin/kubernetes/kubernetes.go index 9eac7d467..9c5089bd7 100644 --- a/plugin/kubernetes/kubernetes.go +++ b/plugin/kubernetes/kubernetes.go @@ -414,7 +414,7 @@ func (k *Kubernetes) findServices(r recordRequest, zone string) (services []msg. err = errNoItems if wildcard(r.service) && !wildcard(r.namespace) { // If namespace exist, err should be nil, so that we return nodata instead of NXDOMAIN - if k.namespace(namespace) { + if k.namespace(r.namespace) { err = nil } } -- cgit v1.2.3