Add stateful application failover status injection feature gate

Signed-off-by: RainbowMango <qdurenhongcai@gmail.com>

api/openapi-spec/swagger.json

@@ -18291,7 +18291,7 @@
           "type": "string"
         },
         "statePreservation": {
-          "description": "StatePreservation defines the policy for preserving and restoring state data during failover events for stateful applications.\n\nWhen an application fails over from one cluster to another, this policy enables the extraction of critical data from the original resource configuration. Upon successful migration, the extracted data is then re-injected into the new resource, ensuring that the application can resume operation with its previous state intact. This is particularly useful for stateful applications where maintaining data consistency across failover events is crucial. If not specified, means no state data will be preserved.",
+          "description": "StatePreservation defines the policy for preserving and restoring state data during failover events for stateful applications.\n\nWhen an application fails over from one cluster to another, this policy enables the extraction of critical data from the original resource configuration. Upon successful migration, the extracted data is then re-injected into the new resource, ensuring that the application can resume operation with its previous state intact. This is particularly useful for stateful applications where maintaining data consistency across failover events is crucial. If not specified, means no state data will be preserved.\n\nNote: This requires the StatefulFailoverInjection feature gate to be enabled, which is alpha.",
           "$ref": "#/definitions/com.github.karmada-io.karmada.pkg.apis.policy.v1alpha1.StatePreservation"
         }
       }

artifacts/deploy/karmada-controller-manager.yaml

@@ -30,7 +30,7 @@ spec:
             - --cluster-status-update-frequency=10s
             - --failover-eviction-timeout=30s
             - --controllers=*,hpaScaleTargetMarker,deploymentReplicasSyncer
-            - --feature-gates=PropagationPolicyPreemption=true,MultiClusterService=true
+            - --feature-gates=PropagationPolicyPreemption=true,MultiClusterService=true,StatefulFailoverInjection=true
             - --health-probe-bind-address=0.0.0.0:10357
             - --v=4
           livenessProbe:

charts/karmada/_crds/bases/policy/policy.karmada.io_clusterpropagationpolicies.yaml

@@ -177,6 +177,9 @@ spec:
                           This is particularly useful for stateful applications where maintaining data
                           consistency across failover events is crucial.
                           If not specified, means no state data will be preserved.
+
+                          Note: This requires the StatefulFailoverInjection feature gate to be enabled,
+                          which is alpha.
                         properties:
                           rules:
                             description: |-

charts/karmada/_crds/bases/policy/policy.karmada.io_propagationpolicies.yaml

@@ -174,6 +174,9 @@ spec:
                           This is particularly useful for stateful applications where maintaining data
                           consistency across failover events is crucial.
                           If not specified, means no state data will be preserved.
+
+                          Note: This requires the StatefulFailoverInjection feature gate to be enabled,
+                          which is alpha.
                         properties:
                           rules:
                             description: |-

charts/karmada/_crds/bases/work/work.karmada.io_clusterresourcebindings.yaml

@@ -339,6 +339,9 @@ spec:
                           This is particularly useful for stateful applications where maintaining data
                           consistency across failover events is crucial.
                           If not specified, means no state data will be preserved.
+
+                          Note: This requires the StatefulFailoverInjection feature gate to be enabled,
+                          which is alpha.
                         properties:
                           rules:
                             description: |-

charts/karmada/_crds/bases/work/work.karmada.io_resourcebindings.yaml

@@ -339,6 +339,9 @@ spec:
                           This is particularly useful for stateful applications where maintaining data
                           consistency across failover events is crucial.
                           If not specified, means no state data will be preserved.
+
+                          Note: This requires the StatefulFailoverInjection feature gate to be enabled,
+                          which is alpha.
                         properties:
                           rules:
                             description: |-

pkg/apis/policy/v1alpha1/propagation_types.go

@@ -336,6 +336,9 @@ type ApplicationFailoverBehavior struct {
 	// This is particularly useful for stateful applications where maintaining data
 	// consistency across failover events is crucial.
 	// If not specified, means no state data will be preserved.
+	//
+	// Note: This requires the StatefulFailoverInjection feature gate to be enabled,
+	// which is alpha.
 	// +optional
 	StatePreservation *StatePreservation `json:"statePreservation,omitempty"`
 }

pkg/controllers/applicationfailover/common.go

@@ -192,18 +192,20 @@ func buildTaskOptions(failoverBehavior *policyv1alpha1.ApplicationFailoverBehavi
 	taskOpts = append(taskOpts, workv1alpha2.WithReason(workv1alpha2.EvictionReasonApplicationFailure))
 	taskOpts = append(taskOpts, workv1alpha2.WithPurgeMode(failoverBehavior.PurgeMode))
 
-	if failoverBehavior.StatePreservation != nil && len(failoverBehavior.StatePreservation.Rules) != 0 {
-		targetStatusItem, exist := findTargetStatusItemByCluster(aggregatedStatus, cluster)
-		if !exist || targetStatusItem.Status == nil || targetStatusItem.Status.Raw == nil {
-			return nil, fmt.Errorf("the application status has not yet been collected from Cluster(%s)", cluster)
-		}
-		preservedLabelState, err := buildPreservedLabelState(failoverBehavior.StatePreservation, targetStatusItem.Status.Raw)
-		if err != nil {
-			return nil, err
-		}
-		if preservedLabelState != nil {
-			taskOpts = append(taskOpts, workv1alpha2.WithPreservedLabelState(preservedLabelState))
-			taskOpts = append(taskOpts, workv1alpha2.WithClustersBeforeFailover(clustersBeforeFailover))
+	if features.FeatureGate.Enabled(features.StatefulFailoverInjection) {
+		if failoverBehavior.StatePreservation != nil && len(failoverBehavior.StatePreservation.Rules) != 0 {
+			targetStatusItem, exist := findTargetStatusItemByCluster(aggregatedStatus, cluster)
+			if !exist || targetStatusItem.Status == nil || targetStatusItem.Status.Raw == nil {
+				return nil, fmt.Errorf("the application status has not yet been collected from Cluster(%s)", cluster)
+			}
+			preservedLabelState, err := buildPreservedLabelState(failoverBehavior.StatePreservation, targetStatusItem.Status.Raw)
+			if err != nil {
+				return nil, err
+			}
+			if preservedLabelState != nil {
+				taskOpts = append(taskOpts, workv1alpha2.WithPreservedLabelState(preservedLabelState))
+				taskOpts = append(taskOpts, workv1alpha2.WithClustersBeforeFailover(clustersBeforeFailover))
+			}
 		}
 	}
 

pkg/controllers/applicationfailover/common_test.go

@@ -30,6 +30,8 @@ import (
 
 	policyv1alpha1 "github.com/karmada-io/karmada/pkg/apis/policy/v1alpha1"
 	workv1alpha2 "github.com/karmada-io/karmada/pkg/apis/work/v1alpha2"
+	"github.com/karmada-io/karmada/pkg/features"
+
 )
 
 func TestTimeStampProcess(t *testing.T) {
@@ -645,6 +647,7 @@ func Test_buildTaskOptions(t *testing.T) {
 		},
 	}
 	for _, tt := range tests {
+		features.FeatureGate.Set(fmt.Sprintf("%s=%t", features.StatefulFailoverInjection, true))
 		t.Run(tt.name, func(t *testing.T) {
 			got, err := buildTaskOptions(tt.args.failoverBehavior, tt.args.aggregatedStatus, tt.args.cluster, tt.args.producer, tt.args.clustersBeforeFailover)
 			if !tt.wantErr(t, err, fmt.Sprintf("buildTaskOptions(%v, %v, %v, %v, %v)", tt.args.failoverBehavior, tt.args.aggregatedStatus, tt.args.cluster, tt.args.producer, tt.args.clustersBeforeFailover)) {

pkg/controllers/binding/common.go

@@ -28,6 +28,8 @@ import (
 	"k8s.io/utils/ptr"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
+	"github.com/karmada-io/karmada/pkg/features"
+
 	configv1alpha1 "github.com/karmada-io/karmada/pkg/apis/config/v1alpha1"
 	policyv1alpha1 "github.com/karmada-io/karmada/pkg/apis/policy/v1alpha1"
 	workv1alpha2 "github.com/karmada-io/karmada/pkg/apis/work/v1alpha2"
@@ -113,9 +115,11 @@ func ensureWork(
 			return err
 		}
 
-		// we need to figure out if the targetCluster is in the cluster we are going to migrate application to.
-		// If yes, we have to inject the preserved label state to clonedWorkload with the label.
-		clonedWorkload = injectReservedLabelState(bindingSpec, targetCluster, clonedWorkload, len(targetClusters))
+		if features.FeatureGate.Enabled(features.StatefulFailoverInjection) {
+			// we need to figure out if the targetCluster is in the cluster we are going to migrate application to.
+			// If yes, we have to inject the preserved label state to the clonedWorkload.
+			clonedWorkload = injectReservedLabelState(bindingSpec, targetCluster, clonedWorkload, len(targetClusters))
+		}
 
 		workMeta := metav1.ObjectMeta{
 			Name:        names.GenerateWorkName(clonedWorkload.GetKind(), clonedWorkload.GetName(), clonedWorkload.GetNamespace()),

pkg/features/features.go

@@ -43,6 +43,15 @@ const (
 
 	// ResourceQuotaEstimate indicates if enable resource quota check in estimator
 	ResourceQuotaEstimate featuregate.Feature = "ResourceQuotaEstimate"
+
+	// StatefulFailoverInjection controls whether Karmada collects state information
+	// from the source cluster during a failover event for stateful applications and
+	// injects this information into the application configuration when it is moved
+	// to the target cluster.
+	//
+	// owner: @mszacillo, @XiShanYongYe-Chang
+	// alpha: v1.12
+	StatefulFailoverInjection featuregate.Feature = "StatefulFailoverInjection"
 )
 
 var (
@@ -58,6 +67,7 @@ var (
 		PolicyPreemption:                  {Default: false, PreRelease: featuregate.Alpha},
 		MultiClusterService:               {Default: false, PreRelease: featuregate.Alpha},
 		ResourceQuotaEstimate:             {Default: false, PreRelease: featuregate.Alpha},
+		StatefulFailoverInjection:         {Default: false, PreRelease: featuregate.Alpha},
 	}
 )