koord-descheduler: LowNodeLoad supports anomaly detector

pkg/descheduler/apis/config/types_loadaware.go

@@ -64,6 +64,11 @@ type LowNodeLoadArgs struct {
 
 	// LowThresholds defines the low usage threshold of resources
 	LowThresholds ResourceThresholds
+
+	// AnomalyCondition indicates the node load anomaly thresholds,
+	// the default is 5 consecutive times exceeding HighThresholds,
+	// it is determined that the node is abnormal, and the Pods need to be migrated to reduce the load.
+	AnomalyCondition *LoadAnomalyCondition
 }
 
 type LowNodeLoadPodSelector struct {
@@ -72,3 +77,10 @@ type LowNodeLoadPodSelector struct {
 	// Selector label query over pods for migrated
 	Selector *metav1.LabelSelector
 }
+
+type LoadAnomalyCondition struct {
+	// Timeout indicates the expiration time of the abnormal state, the default is 1 minute
+	Timeout metav1.Duration
+	// ConsecutiveAbnormalities indicates the number of consecutive abnormalities
+	ConsecutiveAbnormalities uint32
+}

pkg/descheduler/apis/config/v1alpha2/defaults.go

@@ -49,6 +49,11 @@ var (
 			Duration: metav1.Duration{Duration: 5 * time.Minute},
 		},
 	}
+
+	defaultLoadAnomalyCondition = &LoadAnomalyCondition{
+		Timeout:                  &metav1.Duration{Duration: 1 * time.Minute},
+		ConsecutiveAbnormalities: 5,
+	}
 )
 
 func addDefaultingFuncs(scheme *runtime.Scheme) error {
@@ -247,4 +252,7 @@ func SetDefaults_LowNodeLoadArgs(obj *LowNodeLoadArgs) {
 	if obj.NodeFit == nil {
 		obj.NodeFit = pointer.Bool(true)
 	}
+	if obj.AnomalyCondition == nil || obj.AnomalyCondition.ConsecutiveAbnormalities == 0 {
+		obj.AnomalyCondition = defaultLoadAnomalyCondition
+	}
 }

pkg/descheduler/apis/config/v1alpha2/types_loadaware.go

@@ -63,6 +63,11 @@ type LowNodeLoadArgs struct {
 
 	// LowThresholds defines the low usage threshold of resources
 	LowThresholds ResourceThresholds `json:"lowThresholds,omitempty"`
+
+	// AnomalyCondition indicates the node load anomaly thresholds,
+	// the default is 5 consecutive times exceeding HighThresholds,
+	// it is determined that the node is abnormal, and the Pods need to be migrated to reduce the load.
+	AnomalyCondition *LoadAnomalyCondition `json:"anomalyCondition,omitempty"`
 }
 
 type LowNodeLoadPodSelector struct {
@@ -71,3 +76,10 @@ type LowNodeLoadPodSelector struct {
 	// Selector label query over pods for migrated
 	Selector *metav1.LabelSelector `json:"selector,omitempty"`
 }
+
+type LoadAnomalyCondition struct {
+	// Timeout indicates the expiration time of the abnormal state, the default is 1 minute
+	Timeout *metav1.Duration `json:"timeout,omitempty"`
+	// ConsecutiveAbnormalities indicates the number of consecutive abnormalities
+	ConsecutiveAbnormalities uint32 `json:"consecutiveAbnormalities,omitempty"`
+}

pkg/descheduler/apis/config/validation/validation_loadaware.go

@@ -62,6 +62,11 @@ func ValidateLowLoadUtilizationArgs(path *field.Path, args *deschedulerconfig.Lo
 		}
 	}
 
+	if args.AnomalyCondition.ConsecutiveAbnormalities <= 0 {
+		fieldPath := path.Child("anomalyDetectionThresholds").Child("consecutiveAbnormalities")
+		allErrs = append(allErrs, field.Invalid(fieldPath, args.AnomalyCondition.ConsecutiveAbnormalities, "consecutiveAbnormalities must be greater than 0"))
+	}
+
 	if len(allErrs) == 0 {
 		return nil
 	}