feat: compatible shardingSpecs and instances for cluster (#7101)

apis/apps/v1alpha1/cluster_types.go

@@ -475,7 +475,7 @@ type InstanceTemplate struct {
 	// Defines VolumeClaimTemplates to override.
 	// Add new or override existing volume claim templates.
 	// +optional
-	VolumeClaimTemplates []corev1.PersistentVolumeClaim `json:"volumeClaimTemplates,omitempty"`
+	VolumeClaimTemplates []ClusterComponentVolumeClaimTemplate `json:"volumeClaimTemplates,omitempty"`
 }
 
 // ClusterStatus defines the observed state of Cluster.
@@ -804,6 +804,10 @@ type ClusterComponentSpec struct {
 	// Any remaining replicas will be generated using the default template and will follow the default naming rules.
 	//
 	// +optional
+	// +patchMergeKey=name
+	// +patchStrategy=merge,retainKeys
+	// +listType=map
+	// +listMapKey=name
 	Instances []InstanceTemplate `json:"instances,omitempty" patchStrategy:"merge,retainKeys" patchMergeKey:"name"`
 
 	// Specifies the names of instances to be transitioned to offline status.
@@ -1420,6 +1424,15 @@ func (r ClusterSpec) GetComponentByName(componentName string) *ClusterComponentS
 	return nil
 }
 
+func (r ClusterSpec) GetShardingByName(shardingName string) *ShardingSpec {
+	for _, v := range r.ShardingSpecs {
+		if v.Name == shardingName {
+			return &v
+		}
+	}
+	return nil
+}
+
 // GetComponentDefRefName gets the name of referenced component definition.
 func (r ClusterSpec) GetComponentDefRefName(componentName string) string {
 	for _, component := range r.ComponentSpecs {