feat: add new cluster phase ClusterRecovering (#2320)

1996wentaozhang · wtaozzhang · web-flow · commit 3adc0f440d6f · 2024-06-06T14:42:07.000+08:00
Co-authored-by: wtaozzhang &lt;wtaozzhang@tencent.com&gt;
diff --git a/api/platform/types.go b/api/platform/types.go
@@ -330,6 +330,8 @@ const (
 	ClusterUpscaling ClusterPhase = "Upscaling"
 	// ClusterDownscaling means the cluster is undergoing graceful down scaling.
 	ClusterDownscaling ClusterPhase = "Downscaling"
+	// ClusterRecovering means the cluster is recovering form confined.
+	ClusterRecovering ClusterPhase = "Recovering"
 )
 
 // ComponentPhase defines the phase of anywhere cluster component
diff --git a/api/platform/v1/types.go b/api/platform/v1/types.go
@@ -345,6 +345,8 @@ const (
 	ClusterUpscaling ClusterPhase = "Upscaling"
 	// ClusterDownscaling means the cluster is undergoing graceful down scaling.
 	ClusterDownscaling ClusterPhase = "Downscaling"
+	// ClusterRecovering means the cluster is recovering form confined.
+	ClusterRecovering ClusterPhase = "Recovering"
 )
 
 // ComponentPhase defines the phase of anywhere cluster component
diff --git a/pkg/platform/controller/cluster/cluster_controller.go b/pkg/platform/controller/cluster/cluster_controller.go
@@ -358,7 +358,7 @@ func (c *Controller) reconcile(ctx context.Context, key string, cluster *platfor
 		err = c.onUpdate(ctx, cluster)
 	case platformv1.ClusterUpscaling, platformv1.ClusterDownscaling:
 		err = c.onUpdate(ctx, cluster)
-	case platformv1.ClusterIdling, platformv1.ClusterConfined:
+	case platformv1.ClusterIdling, platformv1.ClusterConfined, platformv1.ClusterRecovering:
 		err = c.onUpdate(ctx, cluster)
 	case platformv1.ClusterTerminating:
 		log.FromContext(ctx).Info("Cluster has been terminated. Attempting to cleanup resources")
@@ -444,7 +444,8 @@ func (c *Controller) onUpdate(ctx context.Context, cluster *platformv1.Cluster)
 	if clusterWrapper.Status.Phase == platformv1.ClusterRunning ||
 		clusterWrapper.Status.Phase == platformv1.ClusterFailed ||
 		clusterWrapper.Status.Phase == platformv1.ClusterIdling ||
-		clusterWrapper.Status.Phase == platformv1.ClusterConfined {
+		clusterWrapper.Status.Phase == platformv1.ClusterConfined ||
+		clusterWrapper.Status.Phase == platformv1.ClusterRecovering {
 		err = provider.OnUpdate(ctx, clusterWrapper)
 		clusterWrapper = c.checkHealth(ctx, clusterWrapper)
 		if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -330,6 +330,8 @@ const (`
`330`	`330`	`ClusterUpscaling ClusterPhase = "Upscaling"`
`331`	`331`	`// ClusterDownscaling means the cluster is undergoing graceful down scaling.`
`332`	`332`	`ClusterDownscaling ClusterPhase = "Downscaling"`
	`333`	`+ // ClusterRecovering means the cluster is recovering form confined.`
	`334`	`+ ClusterRecovering ClusterPhase = "Recovering"`
`333`	`335`	`)`
`334`	`336`
`335`	`337`	`// ComponentPhase defines the phase of anywhere cluster component`
Original file line number	Diff line number	Diff line change
`@@ -345,6 +345,8 @@ const (`
`345`	`345`	`ClusterUpscaling ClusterPhase = "Upscaling"`
`346`	`346`	`// ClusterDownscaling means the cluster is undergoing graceful down scaling.`
`347`	`347`	`ClusterDownscaling ClusterPhase = "Downscaling"`
	`348`	`+ // ClusterRecovering means the cluster is recovering form confined.`
	`349`	`+ ClusterRecovering ClusterPhase = "Recovering"`
`348`	`350`	`)`
`349`	`351`
`350`	`352`	`// ComponentPhase defines the phase of anywhere cluster component`