kubernetes
/
autoscaler
mirror of https://github.com/kubernetes/autoscaler.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix listers in CA after godep update

This commit is contained in:
Marcin Wielgus 2017-08-14 00:14:31 +02:00
parent 69316cbd26
commit b8c1fc2b01
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cluster-autoscaler/utils/kubernetes/listers.go
View File

@ -142,7 +142,7 @@ func NewUnschedulablePodInNamespaceLister(kubeClient client.Interface, namespace
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
podLister := v1lister.NewPodLister(store) podLister := v1lister.NewPodLister(store)
podReflector := cache.NewReflector(podListWatch, &apiv1.Pod{}, store, time.Hour) podReflector := cache.NewReflector(podListWatch, &apiv1.Pod{}, store, time.Hour)
podReflector.Run(stopchannel) go podReflector.Run(stopchannel)
return &UnschedulablePodLister{ return &UnschedulablePodLister{
podLister: podLister, podLister: podLister,
} }
@ -167,7 +167,7 @@ func NewScheduledPodLister(kubeClient client.Interface, stopchannel <-chan struc
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
podLister := v1lister.NewPodLister(store) podLister := v1lister.NewPodLister(store)
podReflector := cache.NewReflector(podListWatch, &apiv1.Pod{}, store, time.Hour) podReflector := cache.NewReflector(podListWatch, &apiv1.Pod{}, store, time.Hour)
podReflector.Run(stopchannel) go podReflector.Run(stopchannel)
return &ScheduledPodLister{ return &ScheduledPodLister{
podLister: podLister, podLister: podLister,
@ -205,7 +205,7 @@ func NewReadyNodeLister(kubeClient client.Interface, stopChannel <-chan struct{}
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
nodeLister := v1lister.NewNodeLister(store) nodeLister := v1lister.NewNodeLister(store)
reflector := cache.NewReflector(listWatcher, &apiv1.Node{}, store, time.Hour) reflector := cache.NewReflector(listWatcher, &apiv1.Node{}, store, time.Hour)
reflector.Run(stopChannel) go reflector.Run(stopChannel)
return &ReadyNodeLister{ return &ReadyNodeLister{
nodeLister: nodeLister, nodeLister: nodeLister,
} }
@ -235,7 +235,7 @@ func NewAllNodeLister(kubeClient client.Interface, stopchannel <-chan struct{})
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
nodeLister := v1lister.NewNodeLister(store) nodeLister := v1lister.NewNodeLister(store)
reflector := cache.NewReflector(listWatcher, &apiv1.Node{}, store, time.Hour) reflector := cache.NewReflector(listWatcher, &apiv1.Node{}, store, time.Hour)
reflector.Run(stopchannel) go reflector.Run(stopchannel)
return &AllNodeLister{ return &AllNodeLister{
nodeLister: nodeLister, nodeLister: nodeLister,
} }
@ -257,7 +257,7 @@ func NewPodDisruptionBudgetLister(kubeClient client.Interface, stopchannel <-cha
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
pdbLister := v1policylister.NewPodDisruptionBudgetLister(store) pdbLister := v1policylister.NewPodDisruptionBudgetLister(store)
reflector := cache.NewReflector(listWatcher, &policyv1.PodDisruptionBudget{}, store, time.Hour) reflector := cache.NewReflector(listWatcher, &policyv1.PodDisruptionBudget{}, store, time.Hour)
reflector.Run(stopchannel) go reflector.Run(stopchannel)
return &PodDisruptionBudgetLister{ return &PodDisruptionBudgetLister{
pdbLister: pdbLister, pdbLister: pdbLister,
} }
@ -279,7 +279,7 @@ func NewDaemonSetLister(kubeClient client.Interface, stopchannel <-chan struct{}
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
lister := v1extensionslister.NewDaemonSetLister(store) lister := v1extensionslister.NewDaemonSetLister(store)
reflector := cache.NewReflector(listWatcher, &extensionsv1.DaemonSet{}, store, time.Hour) reflector := cache.NewReflector(listWatcher, &extensionsv1.DaemonSet{}, store, time.Hour)
reflector.Run(stopchannel) go reflector.Run(stopchannel)
return &DaemonSetLister{ return &DaemonSetLister{
daemonSetLister: lister, daemonSetLister: lister,
} }