diff options
author | 2016-09-16 08:31:23 -0700 | |
---|---|---|
committer | 2016-09-16 16:31:23 +0100 | |
commit | 50d47a55a277ea3521efe822b1faea4e93610c24 (patch) | |
tree | b43004857b6982cd29e7be0a4aee0664d5af51bc /middleware/kubernetes/controller.go | |
parent | 953cfc1de49ffe9748a876c16b4b45c3f518f6d1 (diff) | |
download | coredns-50d47a55a277ea3521efe822b1faea4e93610c24.tar.gz coredns-50d47a55a277ea3521efe822b1faea4e93610c24.tar.zst coredns-50d47a55a277ea3521efe822b1faea4e93610c24.zip |
Fix build error by change kubernetes controller to `pkg/client/cache` (#262)
Kubernetes moves informer and controller to pkg/client/cache, see:
https://github.com/kubernetes/kubernetes/pull/32718
As a result, coredns build is broken.
This fix fixes the build by making related change with kubernetes.
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
Diffstat (limited to 'middleware/kubernetes/controller.go')
-rw-r--r-- | middleware/kubernetes/controller.go | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/middleware/kubernetes/controller.go b/middleware/kubernetes/controller.go index 5de16d61c..126d415ae 100644 --- a/middleware/kubernetes/controller.go +++ b/middleware/kubernetes/controller.go @@ -10,7 +10,6 @@ import ( "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/client/cache" client "k8s.io/kubernetes/pkg/client/unversioned" - "k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/watch" @@ -25,9 +24,9 @@ type dnsController struct { selector *labels.Selector - endpController *framework.Controller - svcController *framework.Controller - nsController *framework.Controller + endpController *cache.Controller + svcController *cache.Controller + nsController *cache.Controller svcLister cache.StoreToServiceLister endpLister cache.StoreToEndpointsLister @@ -49,26 +48,26 @@ func newdnsController(kubeClient *client.Client, resyncPeriod time.Duration, lse stopCh: make(chan struct{}), } - dns.endpLister.Store, dns.endpController = framework.NewInformer( + dns.endpLister.Store, dns.endpController = cache.NewInformer( &cache.ListWatch{ ListFunc: endpointsListFunc(dns.client, namespace, dns.selector), WatchFunc: endpointsWatchFunc(dns.client, namespace, dns.selector), }, - &api.Endpoints{}, resyncPeriod, framework.ResourceEventHandlerFuncs{}) + &api.Endpoints{}, resyncPeriod, cache.ResourceEventHandlerFuncs{}) - dns.svcLister.Store, dns.svcController = framework.NewInformer( + dns.svcLister.Store, dns.svcController = cache.NewInformer( &cache.ListWatch{ ListFunc: serviceListFunc(dns.client, namespace, dns.selector), WatchFunc: serviceWatchFunc(dns.client, namespace, dns.selector), }, - &api.Service{}, resyncPeriod, framework.ResourceEventHandlerFuncs{}) + &api.Service{}, resyncPeriod, cache.ResourceEventHandlerFuncs{}) - dns.nsLister.Store, dns.nsController = framework.NewInformer( + dns.nsLister.Store, dns.nsController = cache.NewInformer( &cache.ListWatch{ ListFunc: namespaceListFunc(dns.client, dns.selector), WatchFunc: namespaceWatchFunc(dns.client, dns.selector), }, - &api.Namespace{}, resyncPeriod, framework.ResourceEventHandlerFuncs{}) + &api.Namespace{}, resyncPeriod, cache.ResourceEventHandlerFuncs{}) return &dns } |