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

Implement mirror pod check.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-08-01 11:21:43 -04:00
parent 4ad64d2ad4
commit 062b8698c7
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/rescheduler/pod/pods.go
View File

@@ -22,10 +22,7 @@ import (
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/api/v1/helper/qos"
"k8s.io/kubernetes/pkg/client/clientset_generated/clientset"
)
const (
criticalPodAnnotation = "scheduler.alpha.kubernetes.io/critical-pod"
"k8s.io/kubernetes/pkg/kubelet/types"
)
func ListPodsOnANode(client clientset.Interface, node *v1.Node) ([]*v1.Pod, error) {
@@ -44,8 +41,7 @@ func ListPodsOnANode(client clientset.Interface, node *v1.Node) ([]*v1.Pod, erro
}
func IsCriticalPod(pod *v1.Pod) bool {
_, found := pod.ObjectMeta.Annotations[criticalPodAnnotation]
return found
return types.IsCriticalPod(pod * v1.Pod)
}
func IsBestEffortPod(pod *v1.Pod) bool {
@@ -59,3 +55,12 @@ func IsBurstablePod(pod *v1.Pod) bool {
func IsGuaranteedPod(pod *v1.Pod) bool {
return qos.GetPodQOS(pod) == v1.PodQOSGuaranteed
}
func IsDaemonsetPod(pod *v1.Pod) bool {
}
// IsMirrorPod checks whether the pod is a mirror pod.
func IsMirrorPod(pod *apiv1.Pod) bool {
_, found := pod.ObjectMeta.Annotations[types.ConfigMirrorAnnotationKey]
return found
}