feat: support rolling update in the cluster API

apis/apps/v1/cluster_types.go

@@ -438,6 +438,11 @@ type ClusterComponentSpec struct {
 	// +optional
 	PodUpdatePolicy *PodUpdatePolicyType `json:"podUpdatePolicy,omitempty"`
 
+	// Provides fine-grained control over the spec update process of all instances.
+	//
+	// +optional
+	InstanceUpdateStrategy *InstanceUpdateStrategy `json:"instanceUpdateStrategy,omitempty"`
+
 	// Allows for the customization of configuration values for each instance within a Component.
 	// An instance represent a single replica (Pod and associated K8s resources like PVCs, Services, and ConfigMaps).
 	// While instances typically share a common configuration as defined in the ClusterComponentSpec,

apis/apps/v1/component_types.go

@@ -212,6 +212,11 @@ type ComponentSpec struct {
 	// +optional
 	PodUpdatePolicy *PodUpdatePolicyType `json:"podUpdatePolicy,omitempty"`
 
+	// Provides fine-grained control over the spec update process of all instances.
+	//
+	// +optional
+	InstanceUpdateStrategy *InstanceUpdateStrategy `json:"instanceUpdateStrategy,omitempty"`
+
 	// Specifies the scheduling policy for the Component.
 	//
 	// +optional

apis/apps/v1/types.go

@@ -18,6 +18,7 @@ package v1
 
 import (
 	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/util/intstr"
 )
 
 const (
@@ -526,6 +527,59 @@ const (
 	PreferInPlacePodUpdatePolicyType PodUpdatePolicyType = "PreferInPlace"
 )
 
+// InstanceUpdateStrategy defines fine-grained control over the spec update process of all instances.
+type InstanceUpdateStrategy struct {
+	// Indicates the type of the update strategy.
+	// Default is RollingUpdate.
+	//
+	// +optional
+	Type InstanceUpdateStrategyType `json:"type,omitempty"`
+
+	// Specifies how the rolling update should be applied.
+	//
+	// +optional
+	RollingUpdate *RollingUpdate `json:"rollingUpdate,omitempty"`
+}
+
+// InstanceUpdateStrategyType is a string enumeration type that enumerates
+// all possible update strategies for the KubeBlocks controllers.
+//
+// +enum
+// +kubebuilder:validation:Enum={RollingUpdate,OnDelete}
+type InstanceUpdateStrategyType string
+
+const (
+	// RollingUpdateStrategyType indicates that update will be
+	// applied to all Instances with respect to the workload
+	// ordering constraints.
+	RollingUpdateStrategyType InstanceUpdateStrategyType = "RollingUpdate"
+	// OnDeleteStrategyType indicates that ordered rolling restarts are disabled. Instances are recreated
+	// when they are manually deleted.
+	OnDeleteStrategyType InstanceUpdateStrategyType = "OnDelete"
+)
+
+// RollingUpdate specifies how the rolling update should be applied.
+type RollingUpdate struct {
+	// Indicates the number of instances that should be updated during a rolling update.
+	// The remaining instances will remain untouched. This is helpful in defining how many instances
+	// should participate in the update process.
+	// Value can be an absolute number (ex: 5) or a percentage of desired instances (ex: 10%).
+	// Absolute number is calculated from percentage by rounding up.
+	// The default value is ComponentSpec.Replicas (i.e., update all instances).
+	//
+	// +optional
+	Replicas *intstr.IntOrString `json:"replicas,omitempty"`
+
+	// The maximum number of instances that can be unavailable during the update.
+	// Value can be an absolute number (ex: 5) or a percentage of desired instances (ex: 10%).
+	// Absolute number is calculated from percentage by rounding up. This can not be 0.
+	// Defaults to 1. The field applies to all instances. That means if there is any unavailable pod,
+	// it will be counted towards MaxUnavailable.
+	//
+	// +optional
+	MaxUnavailable *intstr.IntOrString `json:"maxUnavailable,omitempty"`
+}
+
 type SchedulingPolicy struct {
 	// If specified, the Pod will be dispatched by specified scheduler.
 	// If not specified, the Pod will be dispatched by default scheduler.

apis/workloads/v1/instanceset_types.go

@@ -184,13 +184,20 @@ type InstanceSetSpec struct {
 	// +optional
 	PodUpdatePolicy PodUpdatePolicyType `json:"podUpdatePolicy,omitempty"`
 
-	// Indicates the StatefulSetUpdateStrategy that will be
-	// employed to update Pods in the InstanceSet when a revision is made to
-	// Template.
-	// UpdateStrategy.Type will be set to appsv1.OnDeleteStatefulSetStrategyType if MemberUpdateStrategy is not nil
+	// Provides fine-grained control over the spec update process of all instances.
 	//
-	// Note: This field will be removed in future version.
-	UpdateStrategy appsv1.StatefulSetUpdateStrategy `json:"updateStrategy,omitempty"`
+	// +optional
+	InstanceUpdateStrategy *InstanceUpdateStrategy `json:"instanceUpdateStrategy,omitempty"`
+
+	// Members(Pods) update strategy.
+	//
+	// - serial: update Members one by one that guarantee minimum component unavailable time.
+	// - parallel: force parallel
+	// - bestEffortParallel: update Members in parallel that guarantee minimum component un-writable time.
+	//
+	// +kubebuilder:validation:Enum={Serial,Parallel,BestEffortParallel}
+	// +optional
+	MemberUpdateStrategy *MemberUpdateStrategy `json:"memberUpdateStrategy,omitempty"`
 
 	// A list of roles defined in the system. Instanceset obtains role through pods' role label `kubeblocks.io/role`.
 	//
@@ -207,16 +214,6 @@ type InstanceSetSpec struct {
 	// +optional
 	TemplateVars map[string]string `json:"templateVars,omitempty"`
 
-	// Members(Pods) update strategy.
-	//
-	// - serial: update Members one by one that guarantee minimum component unavailable time.
-	// - bestEffortParallel: update Members in parallel that guarantee minimum component un-writable time.
-	// - parallel: force parallel
-	//
-	// +kubebuilder:validation:Enum={Serial,BestEffortParallel,Parallel}
-	// +optional
-	MemberUpdateStrategy *MemberUpdateStrategy `json:"memberUpdateStrategy,omitempty"`
-
 	// Indicates that the InstanceSet is paused, meaning the reconciliation of this InstanceSet object will be paused.
 	// +optional
 	Paused bool `json:"paused,omitempty"`
@@ -308,16 +305,29 @@ type InstanceSetStatus struct {
 // +kubebuilder:object:generate=false
 type InstanceTemplate = kbappsv1.InstanceTemplate
 
-type PodUpdatePolicyType string
+// PodUpdatePolicyType indicates how pods should be updated
+//
+// +kubebuilder:object:generate=false
+type PodUpdatePolicyType = kbappsv1.PodUpdatePolicyType
 
-const (
-	// StrictInPlacePodUpdatePolicyType indicates that only allows in-place upgrades.
-	// Any attempt to modify other fields will be rejected.
-	StrictInPlacePodUpdatePolicyType PodUpdatePolicyType = "StrictInPlace"
+// InstanceUpdateStrategy defines fine-grained control over the spec update process of all instances.
+//
+// +kubebuilder:object:generate=false
+type InstanceUpdateStrategy = kbappsv1.InstanceUpdateStrategy
 
-	// PreferInPlacePodUpdatePolicyType indicates that we will first attempt an in-place upgrade of the Pod.
-	// If that fails, it will fall back to the ReCreate, where pod will be recreated.
-	PreferInPlacePodUpdatePolicyType PodUpdatePolicyType = "PreferInPlace"
+// RollingUpdate specifies how the rolling update should be applied.
+//
+// +kubebuilder:object:generate=false
+type RollingUpdate = kbappsv1.RollingUpdate
+
+// MemberUpdateStrategy defines Cluster Component update strategy.
+// +enum
+type MemberUpdateStrategy string
+
+const (
+	SerialUpdateStrategy             MemberUpdateStrategy = "Serial"
+	ParallelUpdateStrategy           MemberUpdateStrategy = "Parallel"
+	BestEffortParallelUpdateStrategy MemberUpdateStrategy = "BestEffortParallel"
 )
 
 // ReplicaRole represents a role that can be assigned to a component instance, defining its behavior and responsibilities.
@@ -404,16 +414,6 @@ type MembershipReconfiguration struct {
 	Switchover *kbappsv1.Action `json:"switchover,omitempty"`
 }
 
-// MemberUpdateStrategy defines Cluster Component update strategy.
-// +enum
-type MemberUpdateStrategy string
-
-const (
-	SerialUpdateStrategy             MemberUpdateStrategy = "Serial"
-	BestEffortParallelUpdateStrategy MemberUpdateStrategy = "BestEffortParallel"
-	ParallelUpdateStrategy           MemberUpdateStrategy = "Parallel"
-)
-
 type MemberStatus struct {
 	// Represents the name of the pod.
 	//