added maxUnhealthyCount setting to check_clients_are_healthy task

pkg/coordinator/tasks/check_clients_are_healthy/README.md

@@ -23,6 +23,9 @@ The `check_clients_are_healthy` task is designed to ensure the health of specifi
 - **`minClientCount`**:\
   The minimum number of clients that must match the `clientNamePatterns` and pass the health checks for the task to succeed. A value of 0 indicates that all matching clients need to pass the health check. Use this to set a threshold for the number of healthy clients required by your test scenario.
 
+- **`maxUnhealthyCount`**:\
+  Specifies the maximum number of unhealthy clients allowed before the task fails. A value of 0 means that any unhealthy client will cause the task to fail, enforcing strict health criteria.
+
 ### Defaults
 
 These are the default settings for the `check_clients_are_healthy` task:
@@ -36,4 +39,5 @@ These are the default settings for the `check_clients_are_healthy` task:
     skipExecutionCheck: false
     expectUnhealthy: false
     minClientCount: 0
+    maxUnhealthyCount: -1
 ```

pkg/coordinator/tasks/check_clients_are_healthy/config.go

@@ -13,11 +13,13 @@ type Config struct {
 	SkipExecutionCheck bool           `yaml:"skipExecutionCheck" json:"skipExecutionCheck"`
 	ExpectUnhealthy    bool           `yaml:"expectUnhealthy" json:"expectUnhealthy"`
 	MinClientCount     int            `yaml:"minClientCount" json:"minClientCount"`
+	MaxUnhealthyCount  int            `yaml:"maxUnhealthyCount" json:"maxUnhealthyCount"`
 }
 
 func DefaultConfig() Config {
 	return Config{
-		PollInterval: human.Duration{Duration: 5 * time.Second},
+		PollInterval:      human.Duration{Duration: 5 * time.Second},
+		MaxUnhealthyCount: -1,
 	}
 }
 

pkg/coordinator/tasks/check_clients_are_healthy/task.go

@@ -126,9 +126,12 @@ func (t *Task) processCheck() {
 
 	t.logger.Infof("Check result: %v, Failed Clients: %v", resultPass, failedClients)
 
-	if resultPass {
+	switch {
+	case t.config.MaxUnhealthyCount > -1 && len(failedClients) >= t.config.MaxUnhealthyCount:
+		t.ctx.SetResult(types.TaskResultFailure)
+	case resultPass:
 		t.ctx.SetResult(types.TaskResultSuccess)
-	} else {
+	default:
 		t.ctx.SetResult(types.TaskResultNone)
 	}
 }