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 thresholds logic.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-08-11 14:57:50 -04:00
parent 9fc75c7ce6
commit 41b696bae6
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -36,19 +36,21 @@ func LowNodeUtilization(client clientset.Interface, strategy api.ReschedulerStra
return
}
npm := CreateNodePodsMap(client, nodes)
lowNodes, otherNodes := []*v1.Node{}, []*v1.Node{}
thresholds := strategy.Params.NodeResourceUtilizationThresholds.Thresholds
if thresholds != nil {
nodeUsageMap := NodeUsageMap{}
for node, pods := range npm {
nodeUsageMap[node] = NodeUtilization(node, pods)
fmt.Printf("Node %#v usage: %#v\n", node.Name, nodeUsageMap[node])
if IsNodeWithLowUtilization(nodeUsageMap[node], thresholds) {
lowNodes = append(lowNodes, node)
} else {
otherNodes = append(otherNodes, node)
}
return
}
npm := CreateNodePodsMap(client, nodes)
lowNodes, otherNodes := []*v1.Node{}, []*v1.Node{}
nodeUsageMap := NodeUsageMap{}
for node, pods := range npm {
nodeUsageMap[node] = NodeUtilization(node, pods)
fmt.Printf("Node %#v usage: %#v\n", node.Name, nodeUsageMap[node])
if IsNodeWithLowUtilization(nodeUsageMap[node], thresholds) {
lowNodes = append(lowNodes, node)
} else {
otherNodes = append(otherNodes, node)
}
}