From cc8a3ca4f3706fbcc55b5b3ff184eff887cd9deb Mon Sep 17 00:00:00 2001 From: Avesh Agarwal Date: Mon, 31 Jul 2017 21:03:04 -0400 Subject: [PATCH] Fix node implementation. --- pkg/rescheduler/node/node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/rescheduler/node/node.go b/pkg/rescheduler/node/node.go index 5e3c728c8..cc79c8804 100644 --- a/pkg/rescheduler/node/node.go +++ b/pkg/rescheduler/node/node.go @@ -32,7 +32,7 @@ import ( // ReadyNodes returns ready nodes irrespective of whether they are // schedulable or not. func ReadyNodes(client clientset.Interface, stopChannel <-chan struct{}) ([]*v1.Node, error) { - nl := getNodeLister(client, stopChannel) + nl := GetNodeLister(client, stopChannel) nodes, err := nl.List(labels.Everything()) if err != nil { return []*v1.Node{}, err @@ -59,7 +59,7 @@ func ReadyNodes(client clientset.Interface, stopChannel <-chan struct{}) ([]*v1. return readyNodes, nil } -func getNodeLister(client clientset.Interface, stopChannel <-chan struct{}) corelisters.NodeLister { +func GetNodeLister(client clientset.Interface, stopChannel <-chan struct{}) corelisters.NodeLister { listWatcher := cache.NewListWatchFromClient(client.Core().RESTClient(), "nodes", v1.NamespaceAll, fields.Everything()) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) nodeLister := corelisters.NewNodeLister(store)