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

Update low node utlization strategy.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-08-07 12:58:49 -04:00
parent 79d783caa9
commit 5ade60063a
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/rescheduler/resheduler.go
View File

@@ -67,7 +67,7 @@ func Run(rs *options.ReschedulerServer) error {
if reschedulerPolicy != nil {
fmt.Printf("\nreschedulerPolicy: %#v\n", reschedulerPolicy)
} else {
fmt.Printf("\nreschedulerPolicy is nil\n")
return fmt.Errorf("\nreschedulerPolicy is nil\n")
}
evictionPolicyGroupVersion, err := eutils.SupportEviction(rs.Client)
@@ -82,7 +82,7 @@ func Run(rs *options.ReschedulerServer) error {
}
strategies.RemoveDuplicatePods(rs.Client, evictionPolicyGroupVersion, nodes)
strategies.LowNodeUtilization(rs.Client, evictionPolicyGroupVersion, nodes)
strategies.LowNodeUtilization(rs.Client, reschedulerPolicy.Strategies["LowNodeUtilization"], evictionPolicyGroupVersion, nodes)
return nil
}

2
pkg/rescheduler/strategies/lownodeutilization.go
View File

@@ -31,7 +31,7 @@ import (
type NodeUsageMap map[*v1.Node]api.ResourceThresholds
func LowNodeUtilization(client clientset.Interface, policyGroupVersion string, nodes []*v1.Node) {
func LowNodeUtilization(client clientset.Interface, strategy api.ReschedulerStrategy, evictionPolicyGroupVersion string, nodes []*v1.Node) {
nodeUsageMap := NodeUsageMap{}
for _, node := range nodes {
nodeUsageMap[node] = NodeUtilization(client, node)