Sok3t/descheduler
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/descheduler.git synced 2026-01-26 05:14:13 +01:00
Code Packages Releases Activity

Fix node implementation.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-07-31 21:03:04 -04:00
parent 2285ff5c13
commit cc8a3ca4f3
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/rescheduler/node/node.go
View File

@@ -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)