Sok3t/descheduler
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/descheduler.git synced 2026-01-28 22:57:35 +01:00
Code Packages Releases Activity

Update node implementation.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-07-31 22:27:32 -04:00
parent cc8a3ca4f3
commit 0f3704e8ea
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -59,6 +59,10 @@ func ReadyNodes(client clientset.Interface, stopChannel <-chan struct{}) ([]*v1.
return readyNodes, nil return readyNodes, nil
} }
func IsNodeWithLowResourceUtilization() {
// no op
}
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()) listWatcher := cache.NewListWatchFromClient(client.Core().RESTClient(), "nodes", v1.NamespaceAll, fields.Everything())
store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) store := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})