aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/controller.go
diff options
context:
space:
mode:
authorGravatar Yong Tang <yongtang@users.noreply.github.com> 2016-09-16 08:31:23 -0700
committerGravatar Miek Gieben <miek@miek.nl> 2016-09-16 16:31:23 +0100
commit50d47a55a277ea3521efe822b1faea4e93610c24 (patch)
treeb43004857b6982cd29e7be0a4aee0664d5af51bc /middleware/kubernetes/controller.go
parent953cfc1de49ffe9748a876c16b4b45c3f518f6d1 (diff)
downloadcoredns-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.go19
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
}