Add Reconfigure api

Signed-off-by: ashraful <[email protected]>

apis/kubedb/v1alpha2/singlestore_helpers.go

@@ -324,9 +324,6 @@ func (s *Singlestore) SetDefaults() {
 	}
 
 	if s.Spec.Topology == nil {
-		if s.Spec.Replicas == nil {
-			s.Spec.Replicas = pointer.Int32P(1)
-		}
 		if s.Spec.PodTemplate == nil {
 			s.Spec.PodTemplate = &ofst.PodTemplateSpec{}
 		}

apis/kubedb/v1alpha2/singlestore_types.go

@@ -58,9 +58,6 @@ type SinglestoreSpec struct {
 	// +optional
 	Version string `json:"version"`
 
-	// +optional
-	Replicas *int32 `json:"replicas,omitempty"`
-
 	// Singlestore topology for node specification
 	// +optional
 	Topology *SinglestoreTopology `json:"topology,omitempty"`
@@ -137,6 +134,11 @@ type SinglestoreNode struct {
 	// +optional
 	Suffix string `json:"suffix,omitempty"`
 
+	// ConfigSecret is an optional field to provide custom configuration file for database (i.e config.properties).
+	// If specified, this file will be used as configuration file otherwise default configuration file will be used.
+	// +optional
+	ConfigSecret *core.LocalObjectReference `json:"configSecret,omitempty"`
+
 	// Storage to specify how storage shall be used.
 	// +optional
 	Storage *core.PersistentVolumeClaimSpec `json:"storage,omitempty"`

apis/kubedb/v1alpha2/singlestore_webhook.go

@@ -64,15 +64,7 @@ func (s *Singlestore) ValidateCreate() (admission.Warnings, error) {
 func (s *Singlestore) ValidateUpdate(old runtime.Object) (admission.Warnings, error) {
 	singlestorelog.Info("validate update", "name", s.Name)
 
-	oldConnect := old.(*Singlestore)
 	allErr := s.ValidateCreateOrUpdate()
-
-	if s.Spec.Topology == nil && *oldConnect.Spec.Replicas == 1 && *s.Spec.Replicas > 1 {
-		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("replicas"),
-			s.Name,
-			"Cannot scale up from 1 to more than 1 in standalone mode"))
-	}
-
 	if len(allErr) == 0 {
 		return nil, nil
 	}
@@ -111,11 +103,6 @@ func (s *Singlestore) ValidateCreateOrUpdate() field.ErrorList {
 	}
 
 	if s.Spec.Topology == nil {
-		if *s.Spec.Replicas != 1 {
-			allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("replicas"),
-				s.Name,
-				"number of replicas for standalone must be one "))
-		}
 		err := sdbValidateVolumes(s.Spec.PodTemplate)
 		if err != nil {
 			allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("podTemplate").Child("spec").Child("volumes"),

apis/ops/v1alpha1/singlestore_ops_types.go

@@ -61,15 +61,17 @@ type SinglestoreOpsRequestSpec struct {
 	VolumeExpansion *SinglestoreVolumeExpansionSpec `json:"volumeExpansion,omitempty"`
 	// Specifies information necessary for restarting database
 	Restart *RestartSpec `json:"restart,omitempty"`
+	// Specifies information necessary for custom configuration of Singlestore
+	Configuration *SinglestoreCustomConfigurationSpec `json:"configuration,omitempty"`
 	// Timeout for each step of the ops request in second. If a step doesn't finish within the specified timeout, the ops request will result in failure.
 	Timeout *metav1.Duration `json:"timeout,omitempty"`
 	// ApplyOption is to control the execution of OpsRequest depending on the database state.
 	// +kubebuilder:default="IfReady"
 	Apply ApplyOption `json:"apply,omitempty"`
 }
 
-// +kubebuilder:validation:Enum=VerticalScaling;VolumeExpansion;Restart
-// ENUM(VerticalScaling, VolumeExpansion, Restart)
+// +kubebuilder:validation:Enum=VerticalScaling;VolumeExpansion;Restart;Configuration
+// ENUM(VerticalScaling, VolumeExpansion, Restart, Configuration)
 type SinglestoreOpsRequestType string
 
 // SinglestoreVerticalScalingSpec contains the vertical scaling information of a Singlestore cluster
@@ -95,6 +97,18 @@ type SinglestoreVolumeExpansionSpec struct {
 	Leaf *resource.Quantity `json:"leaf,omitempty"`
 }
 
+// SinglestoreCustomConfigurationSpec is the spec for Singlestore reconfiguration
+type SinglestoreCustomConfigurationSpec struct {
+	Aggregator *SinglestoreCustomConfiguration `json:"aggregator,omitempty"`
+	Leaf       *SinglestoreCustomConfiguration `json:"leaf,omitempty"`
+}
+
+type SinglestoreCustomConfiguration struct {
+	ConfigSecret       *core.LocalObjectReference `json:"configSecret,omitempty"`
+	ApplyConfig        map[string]string          `json:"applyConfig,omitempty"`
+	RemoveCustomConfig bool                       `json:"removeCustomConfig,omitempty"`
+}
+
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // SinglestoreOpsRequestList is a list of SinglestoreOpsRequests

crds/kubedb.com_singlestores.yaml

@@ -4138,9 +4138,6 @@ spec:
                         type: array
                     type: object
                 type: object
-              replicas:
-                format: int32
-                type: integer
               serviceTemplates:
                 items:
                   properties:
@@ -4413,6 +4410,12 @@ spec:
                 properties:
                   aggregator:
                     properties:
+                      configSecret:
+                        properties:
+                          name:
+                            type: string
+                        type: object
+                        x-kubernetes-map-type: atomic
                       podPlacementPolicy:
                         default:
                           name: default
@@ -7406,6 +7409,12 @@ spec:
                     type: object
                   leaf:
                     properties:
+                      configSecret:
+                        properties:
+                          name:
+                            type: string
+                        type: object
+                        x-kubernetes-map-type: atomic
                       podPlacementPolicy:
                         default:
                           name: default