feat: support PodManagementPolicy for the instanceSet controller

apis/apps/v1alpha1/componentdefinition_types.go

@@ -19,6 +19,7 @@ package v1alpha1
 import (
 	"time"
 
+	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	rbacv1 "k8s.io/api/rbac/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -443,6 +444,16 @@ type ComponentDefinitionSpec struct {
 	// +optional
 	UpdateStrategy *UpdateStrategy `json:"updateStrategy,omitempty"`
 
+	// InstanceSet controls the creation of pods during initial scale up, replacement of pods on nodes, and scaling down.
+	//
+	// - `OrderedReady`: Creates pods in increasing order (pod-0, then pod-1, etc). The controller waits until each pod
+	// is ready before continuing. Pods are removed in reverse order when scaling down.
+	// - `Parallel`: Creates pods in parallel to match the desired scale without waiting. All pods are deleted at once
+	// when scaling down.
+	//
+	// +optional
+	PodManagementPolicy *appsv1.PodManagementPolicyType `json:"podManagementPolicy,omitempty"`
+
 	// Enumerate all possible roles assigned to each replica of the Component, influencing its behavior.
 	//
 	// A replica can have zero to multiple roles.

config/crd/bases/apps.kubeblocks.io_componentdefinitions.yaml

@@ -5777,6 +5777,16 @@ spec:
                     - scrapePort
                     type: object
                 type: object
+              podManagementPolicy:
+                description: |-
+                  InstanceSet controls the creation of pods during initial scale up, replacement of pods on nodes, and scaling down.
+
+
+                  - `OrderedReady`: Creates pods in increasing order (pod-0, then pod-1, etc). The controller waits until each pod
+                  is ready before continuing. Pods are removed in reverse order when scaling down.
+                  - `Parallel`: Creates pods in parallel to match the desired scale without waiting. All pods are deleted at once
+                  when scaling down.
+                type: string
               policyRules:
                 description: |-
                   Defines the namespaced policy rules required by the Component.

deploy/helm/crds/apps.kubeblocks.io_componentdefinitions.yaml

@@ -5777,6 +5777,16 @@ spec:
                     - scrapePort
                     type: object
                 type: object
+              podManagementPolicy:
+                description: |-
+                  InstanceSet controls the creation of pods during initial scale up, replacement of pods on nodes, and scaling down.
+
+
+                  - `OrderedReady`: Creates pods in increasing order (pod-0, then pod-1, etc). The controller waits until each pod
+                  is ready before continuing. Pods are removed in reverse order when scaling down.
+                  - `Parallel`: Creates pods in parallel to match the desired scale without waiting. All pods are deleted at once
+                  when scaling down.
+                type: string
               policyRules:
                 description: |-
                   Defines the namespaced policy rules required by the Component.

docs/developer_docs/api-reference/cluster.md

@@ -1680,6 +1680,26 @@ at least 3 operational for quorum.</li>
 </tr>
 <tr>
 <td>
+<code>podManagementPolicy</code><br/>
+<em>
+<a href="https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.25/#podmanagementpolicytype-v1-apps">
+Kubernetes apps/v1.PodManagementPolicyType
+</a>
+</em>
+</td>
+<td>
+<em>(Optional)</em>
+<p>InstanceSet controls the creation of pods during initial scale up, replacement of pods on nodes, and scaling down.</p>
+<ul>
+<li><code>OrderedReady</code>: Creates pods in increasing order (pod-0, then pod-1, etc). The controller waits until each pod
+is ready before continuing. Pods are removed in reverse order when scaling down.</li>
+<li><code>Parallel</code>: Creates pods in parallel to match the desired scale without waiting. All pods are deleted at once
+when scaling down.</li>
+</ul>
+</td>
+</tr>
+<tr>
+<td>
 <code>roles</code><br/>
 <em>
 <a href="#apps.kubeblocks.io/v1alpha1.ReplicaRole">
@@ -7696,6 +7716,26 @@ at least 3 operational for quorum.</li>
 </tr>
 <tr>
 <td>
+<code>podManagementPolicy</code><br/>
+<em>
+<a href="https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.25/#podmanagementpolicytype-v1-apps">
+Kubernetes apps/v1.PodManagementPolicyType
+</a>
+</em>
+</td>
+<td>
+<em>(Optional)</em>
+<p>InstanceSet controls the creation of pods during initial scale up, replacement of pods on nodes, and scaling down.</p>
+<ul>
+<li><code>OrderedReady</code>: Creates pods in increasing order (pod-0, then pod-1, etc). The controller waits until each pod
+is ready before continuing. Pods are removed in reverse order when scaling down.</li>
+<li><code>Parallel</code>: Creates pods in parallel to match the desired scale without waiting. All pods are deleted at once
+when scaling down.</li>
+</ul>
+</td>
+</tr>
+<tr>
+<td>
 <code>roles</code><br/>
 <em>
 <a href="#apps.kubeblocks.io/v1alpha1.ReplicaRole">

pkg/controller/component/synthesize_component.go

@@ -147,34 +147,35 @@ func buildSynthesizedComponent(reqCtx intctrlutil.RequestCtx,
 	}
 	compDefObj := compDef.DeepCopy()
 	synthesizeComp := &SynthesizedComponent{
-		Namespace:          comp.Namespace,
-		ClusterName:        clusterName,
-		ClusterUID:         clusterUID,
-		Comp2CompDefs:      comp2CompDef,
-		Name:               compName,
-		FullCompName:       comp.Name,
-		CompDefName:        compDef.Name,
-		ServiceVersion:     comp.Spec.ServiceVersion,
-		ClusterGeneration:  clusterGeneration(cluster, comp),
-		PodSpec:            &compDef.Spec.Runtime,
-		HostNetwork:        compDefObj.Spec.HostNetwork,
-		ComponentServices:  compDefObj.Spec.Services,
-		LogConfigs:         compDefObj.Spec.LogConfigs,
-		ConfigTemplates:    compDefObj.Spec.Configs,
-		ScriptTemplates:    compDefObj.Spec.Scripts,
-		Roles:              compDefObj.Spec.Roles,
-		UpdateStrategy:     compDefObj.Spec.UpdateStrategy,
-		MinReadySeconds:    compDefObj.Spec.MinReadySeconds,
-		PolicyRules:        compDefObj.Spec.PolicyRules,
-		LifecycleActions:   compDefObj.Spec.LifecycleActions,
-		SystemAccounts:     mergeSystemAccounts(compDefObj.Spec.SystemAccounts, comp.Spec.SystemAccounts),
-		Replicas:           comp.Spec.Replicas,
-		Resources:          comp.Spec.Resources,
-		TLSConfig:          comp.Spec.TLSConfig,
-		ServiceAccountName: comp.Spec.ServiceAccountName,
-		Instances:          comp.Spec.Instances,
-		OfflineInstances:   comp.Spec.OfflineInstances,
-		DisableExporter:    comp.Spec.DisableExporter,
+		Namespace:           comp.Namespace,
+		ClusterName:         clusterName,
+		ClusterUID:          clusterUID,
+		Comp2CompDefs:       comp2CompDef,
+		Name:                compName,
+		FullCompName:        comp.Name,
+		CompDefName:         compDef.Name,
+		ServiceVersion:      comp.Spec.ServiceVersion,
+		ClusterGeneration:   clusterGeneration(cluster, comp),
+		PodSpec:             &compDef.Spec.Runtime,
+		HostNetwork:         compDefObj.Spec.HostNetwork,
+		ComponentServices:   compDefObj.Spec.Services,
+		LogConfigs:          compDefObj.Spec.LogConfigs,
+		ConfigTemplates:     compDefObj.Spec.Configs,
+		ScriptTemplates:     compDefObj.Spec.Scripts,
+		Roles:               compDefObj.Spec.Roles,
+		UpdateStrategy:      compDefObj.Spec.UpdateStrategy,
+		MinReadySeconds:     compDefObj.Spec.MinReadySeconds,
+		PolicyRules:         compDefObj.Spec.PolicyRules,
+		LifecycleActions:    compDefObj.Spec.LifecycleActions,
+		SystemAccounts:      mergeSystemAccounts(compDefObj.Spec.SystemAccounts, comp.Spec.SystemAccounts),
+		Replicas:            comp.Spec.Replicas,
+		Resources:           comp.Spec.Resources,
+		TLSConfig:           comp.Spec.TLSConfig,
+		ServiceAccountName:  comp.Spec.ServiceAccountName,
+		Instances:           comp.Spec.Instances,
+		OfflineInstances:    comp.Spec.OfflineInstances,
+		DisableExporter:     comp.Spec.DisableExporter,
+		PodManagementPolicy: compDef.Spec.PodManagementPolicy,
 	}
 
 	// build backward compatible fields, including workload, services, componentRefEnvs, clusterDefName, clusterCompDefName, and clusterCompVer, etc.