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

Update implementation of low node utilization strategy.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-08-15 14:19:25 -04:00
parent 4b62cc9a86
commit a3714c0be4
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -114,32 +114,38 @@ func LowNodeUtilization(client clientset.Interface, strategy api.ReschedulerStra
totalPods += ((float64(podsPercentage) * float64(nodeCapcity.Pods().Value())) / 100) totalPods += ((float64(podsPercentage) * float64(nodeCapcity.Pods().Value())) / 100)
} }
podsPerTargetNode := totalPods / float64(len(targetNodes)) for _, node := range targetNodes {
if podsPerTargetNode > 0 { nodePodsUsage := node.usage[v1.ResourcePods]
for _, node := range targetNodes { nodeCapcity := node.node.Status.Capacity
n := podsPerTargetNode if len(node.node.Status.Allocatable) > 0 {
// evict best effort pods first nodeCapcity = node.node.Status.Allocatable
}
onePodPercentage := api.Percentage((float64(1) * 100) / float64(nodeCapcity.Pods().Value()))
if nodePodsUsage > targetThresholds[v1.ResourcePods] && totalPods > 0 {
for _, pod := range node.bePods { for _, pod := range node.bePods {
success, err := evictions.EvictPod(client, pod, evictionPolicyGroupVersion) success, err := evictions.EvictPod(client, pod, evictionPolicyGroupVersion)
if !success { if !success {
fmt.Printf("Error when evicting pod: %#v (%#v)\n", pod.Name, err) fmt.Printf("Error when evicting pod: %#v (%#v)\n", pod.Name, err)
} else { } else {
fmt.Printf("Evicted pod: %#v (%#v)\n", pod.Name, err) fmt.Printf("Evicted pod: %#v (%#v)\n", pod.Name, err)
n-- nodePodsUsage = nodePodsUsage - onePodPercentage
if n < 0 { totalPods--
if nodePodsUsage <= targetThresholds[v1.ResourcePods] || totalPods <= 0 {
break break
} }
} }
} }
if n > 0 { if nodePodsUsage > targetThresholds[v1.ResourcePods] && totalPods > 0 {
for _, pod := range node.otherPods { for _, pod := range node.otherPods {
success, err := evictions.EvictPod(client, pod, evictionPolicyGroupVersion) success, err := evictions.EvictPod(client, pod, evictionPolicyGroupVersion)
if !success { if !success {
fmt.Printf("Error when evicting pod: %#v (%#v)\n", pod.Name, err) fmt.Printf("Error when evicting pod: %#v (%#v)\n", pod.Name, err)
} else { } else {
fmt.Printf("Evicted pod: %#v (%#v)\n", pod.Name, err) fmt.Printf("Evicted pod: %#v (%#v)\n", pod.Name, err)
n-- nodePodsUsage = nodePodsUsage - onePodPercentage
if n < 0 { totalPods--
if nodePodsUsage <= targetThresholds[v1.ResourcePods] || totalPods <= 0 {
break break
} }
} }