Perceiving the health status of cluster scheduling results in gracefu…

…l evictions

Signed-off-by: changzhen <changzhen5@huawei.com>

pkg/controllers/gracefuleviction/evictiontask.go

@@ -45,16 +45,39 @@ func assessEvictionTasks(bindingSpec workv1alpha2.ResourceBindingSpec,
 }
 
 func assessSingleTask(task workv1alpha2.GracefulEvictionTask, opt assessmentOption) *workv1alpha2.GracefulEvictionTask {
-	// TODO(): gradually evict replica as per observed status.
-
 	// task exceeds timeout
 	if metav1.Now().After(task.CreationTimestamp.Add(opt.timeout)) {
 		return nil
 	}
 
+	// TODO(): gradually evict replica as per observed status.
+	if analyzeHealthOfScheduleResult(opt) {
+		return nil
+	}
+
 	return &task
 }
 
+func analyzeHealthOfScheduleResult(opt assessmentOption) bool {
+	for _, targetCluster := range opt.scheduleResult {
+		var matchStatus *workv1alpha2.AggregatedStatusItem
+		for _, aggregatedStatus := range opt.observedStatus {
+			if aggregatedStatus.ClusterName == targetCluster.Name {
+				matchStatus = &aggregatedStatus
+				break
+			}
+		}
+
+		if matchStatus == nil ||
+			matchStatus.Health == workv1alpha2.ResourceUnhealthy ||
+			matchStatus.Health == workv1alpha2.ResourceUnknown {
+			return false
+		}
+	}
+
+	return true
+}
+
 func nextRetry(tasks []workv1alpha2.GracefulEvictionTask, timeout time.Duration, timeNow time.Time) time.Duration {
 	if len(tasks) == 0 {
 		return 0