feat(storage-node): add reconcile logic

.licenserc.yaml

@@ -42,5 +42,6 @@ header:
     - 'cloudformation/multi-az/*.json'
     - '**/*.json'
     - '**/Cargo.lock'
+    - '**/mocks/**'
 
   comment: on-failure

shardingsphere-operator/Makefile

@@ -53,7 +53,7 @@ fmt: ## Run go fmt against code.
 
 .PHONY: test
 test: manifests generate fmt envtest ## Run tests.
-	KUBEBUILDER_ASSETS="$(shell $(ENVTEST) use $(ENVTEST_K8S_VERSION) -p path)" go test ./... -coverprofile cover.out
+	KUBEBUILDER_ASSETS="$(shell $(ENVTEST) use $(ENVTEST_K8S_VERSION) -p path)" go test -gcflags=-l ./... -coverprofile cover.out
 
 .PHONY: clean
 clean: 

shardingsphere-operator/api/v1alpha1/compute_node_types.go

@@ -68,7 +68,7 @@ type ComputeNodeUser struct {
 	Password string `json:"password"`
 }
 
-// ComputeNodeAuth  is used to set up initial user to login compute node, and authority data of storage node.
+// ComputeNodeAuthority  is used to set up initial user to login compute node, and authority data of storage node.
 type ComputeNodeAuthority struct {
 	Users []ComputeNodeUser `json:"users"`
 	// +optional

shardingsphere-operator/api/v1alpha1/storage_node_types.go

@@ -17,7 +17,65 @@
 
 package v1alpha1
 
-import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+import (
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+type StorageNodePhaseStatus string
+
+const (
+	StorageNodePhaseReady    StorageNodePhaseStatus = "Ready"
+	StorageNodePhaseNotReady StorageNodePhaseStatus = "NotReady"
+)
+
+type StorageNodeConditionType string
+
+// StorageNodeConditionType shows some states during the startup process of storage node
+const (
+	// StorageNodeConditionTypeAvailable means the all the instances and the cluster are ready, and the storage node is ready to provide external services.
+	StorageNodeConditionTypeAvailable StorageNodeConditionType = "Available"
+)
+
+type StorageNodeConditions []*StorageNodeCondition
+
+// StorageNodeCondition contains details for the current condition of this StorageNode.
+type StorageNodeCondition struct {
+	Type           StorageNodeConditionType `json:"type"`
+	Status         corev1.ConditionStatus   `json:"status"`
+	LastUpdateTime metav1.Time              `json:"lastUpdateTime,omitempty"`
+	Reason         string                   `json:"reason"`
+	Message        string                   `json:"message"`
+}
+
+// ClusterStatus is the status of a database cluster, including the primary endpoint, reader endpoints, and other properties.
+// Properties are some additional information about the cluster, like 'arn, identifier, credentials, etc.'
+type ClusterStatus struct {
+	Status          string            `json:"status"`
+	PrimaryEndpoint Endpoint          `json:"primaryEndpoint"`
+	ReaderEndpoints []Endpoint        `json:"readerEndpoints"`
+	Properties      map[string]string `json:"properties"`
+}
+
+type CredentialType struct {
+	BasicCredential `json:"basic_credential"`
+}
+
+type InstanceStatus struct {
+	Status     string            `json:"status"`
+	Endpoint   Endpoint          `json:"primaryEndpoint"`
+	Properties map[string]string `json:"properties"`
+}
+
+type BasicCredential struct {
+	Username string `json:"username"`
+	Password string `json:"password"`
+}
+
+type Endpoint struct {
+	Address string `json:"address"`
+	Port    int32  `json:"port"`
+}
 
 // +kubebuilder:object:root=true
 // StorageNodeList contains a list of StorageNode
@@ -41,7 +99,66 @@ type StorageNode struct {
 }
 
 // StorageNodeSpec defines the desired state of a set of storage units
-type StorageNodeSpec struct{}
+type StorageNodeSpec struct {
+	// +kubebuilder:validation:Required
+	// +kubebuilder:validation:DatabaseClass defined by: https://github.com/database-mesh/golang-sdk/blob/main/kubernetes/api/v1alpha1/databaseclass.go
+	DatabaseClassName string `json:"databaseClassName"`
+	// +optional
+	Schema string `json:"schema"`
+}
 
 // StorageNodeStatus defines the actual state of a set of storage units
-type StorageNodeStatus struct{}
+type StorageNodeStatus struct {
+	// The generation observed by the StorageNode controller.
+	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
+
+	// Phase is a brief summary of the StorageNode life cycle
+	// There are two possible phase values:
+	// Ready: StorageNode can already provide external services
+	// NotReady: StorageNode cannot provide external services
+	// +optional
+	Phase StorageNodePhaseStatus `json:"phase"`
+
+	// Conditions The conditions array, the reason and message fields
+	// +optional
+	Conditions StorageNodeConditions `json:"conditions"`
+
+	// Cluster contains the current status of the StorageNode cluster
+	// +optional
+	Cluster ClusterStatus `json:"cluster,omitempty"`
+
+	// Instance contains the current status of the StorageNode instance
+	// +optional
+	Instances []InstanceStatus `json:"instances,omitempty"`
+}
+
+// AddCondition adds the given condition to the StorageNodeConditions.
+func (c *StorageNodeConditions) AddCondition(condition *StorageNodeCondition) {
+	*c = append(*c, condition)
+}
+
+// UpsertCondition updates the given condition in the StorageNodeConditions.
+func (c *StorageNodeConditions) UpsertCondition(condition *StorageNodeCondition) {
+	for i, existing := range *c {
+		if existing.Type == condition.Type {
+			(*c)[i] = condition
+			return
+		}
+	}
+	c.AddCondition(condition)
+}
+
+// RemoveCondition removes the given condition from the StorageNodeConditions.
+func (c *StorageNodeConditions) RemoveCondition(conditionType StorageNodeConditionType) {
+	var newConditions []*StorageNodeCondition
+	for _, existing := range *c {
+		if existing.Type != conditionType {
+			newConditions = append(newConditions, existing)
+		}
+	}
+	*c = newConditions
+}
+
+func init() {
+	SchemeBuilder.Register(&StorageNode{}, &StorageNodeList{})
+}