Merge pull request #238 from catpineapple/disaggregated_be_scale_down

be scale down and resource clear

Author: intelligentfu8

Dockerfile

@@ -16,7 +16,7 @@
 # under the License.
 
 # Build the manager binary
-FROM golang:1.21.12 as builder
+FROM golang:1.21.12 AS builder
 ARG TARGETOS
 ARG TARGETARCH
 

api/disaggregated/cluster/v1/types.go

@@ -64,7 +64,7 @@ type ComputeCluster struct {
 	//Name is the identifier of computeCluster, name can be used specify what computeCluster to run sql. if not set, will use `computeCluster` and the index in array to set.ep: computeCluster-1.
 	Name string `json:"name,omitempty"`
 
-	//ClusterId is the identifier of computeCluster, this will distinguish all com puteCluster in meta.
+	//ClusterId is the identifier of computeCluster, this will distinguish all computeCluster in meta.
 	ClusterId string `json:"clusterId,omitempty"`
 
 	CommonSpec `json:",inline"`
@@ -294,8 +294,14 @@ const (
 	//Failed represents service failed to start, can't be accessed.
 	Failed Phase = "Failed"
 	//Creating represents service in creating stage.
-	Reconciling          Phase = "Reconciling"
-	ReconclingDropFailed Phase = "ReconclingDropFailed"
+	Reconciling Phase = "Reconciling"
+
+	//Scaling represents service in Scaling.
+	Scaling         Phase = "Scaling"
+	ScaleDownFailed Phase = "ScaleDownFailed"
+	ResumeFailed    Phase = "ResumeFailed"
+	SuspendFailed   Phase = "SuspendFailed"
+	Suspended       Phase = "Suspended"
 )
 
 type AvailableStatus string
@@ -308,6 +314,8 @@ const (
 	UnAvailable AvailableStatus = "UnAvailable"
 )
 
+// AvailableStatus  StatefulsetName  ServiceName
+
 type ComputeClusterStatus struct {
 	//Phase represent the stage of reconciling.
 	Phase Phase `json:"phase,omitempty"`
@@ -321,6 +329,8 @@ type ComputeClusterStatus struct {
 	AvailableStatus AvailableStatus `json:"availableStatus,omitempty"`
 	//ClusterId display  the clusterId of compute cluster in meta.
 	ClusterId string `json:"clusterId,omitempty"`
+	//suspend replicas display the replicas of compute cluster before resume.
+	SuspendReplicas int32 `json:"suspendReplicas,omitempty"`
 
 	// replicas is the number of Pods created by the StatefulSet controller.
 	Replicas int32 `json:"replicas,omitempty"`

api/disaggregated/cluster/v1/unique_id.go

@@ -64,6 +64,7 @@ func (ddc *DorisDisaggregatedCluster) GetInstanceId() string {
 	// need config in vaultConfigMap.
 	return ""
 }
+
 func (ddc *DorisDisaggregatedCluster) GetCCId(cc *ComputeCluster) string {
 	if cc == nil || ddc == nil {
 		return ""

api/disaggregated/cluster/v1/utils.go

@@ -37,3 +37,7 @@ var (
 	DisaggregatedBE DisaggregatedComponentType = "BE"
 	DisaggregatedMS DisaggregatedComponentType = "MS"
 )
+
+const (
+	DefaultMetaserviceNumber int32 = 2
+)