Add RabbitMQ OpsRequests

apis/ops/fuzzer/fuzzer.go

@@ -56,5 +56,8 @@ var Funcs = func(codecs runtimeserializer.CodecFactory) []interface{} {
 		func(s *v1alpha1.RedisOpsRequest, c fuzz.Continue) {
 			c.FuzzNoCustom(s) // fuzz self without calling this function again
 		},
+		func(s *v1alpha1.RabbitMQOpsRequest, c fuzz.Continue) {
+			c.FuzzNoCustom(s) // fuzz self without calling this function again
+		},
 	}
 }

apis/ops/v1alpha1/rabbitmq_ops_types.go

@@ -55,10 +55,18 @@ type RabbitMQOpsRequestSpec struct {
 	DatabaseRef core.LocalObjectReference `json:"databaseRef"`
 	// Specifies the ops request type: UpdateVersion, HorizontalScaling, VerticalScaling etc.
 	Type RabbitMQOpsRequestType `json:"type"`
+	// Specifies information necessary for upgrading rabbitmq
+	UpdateVersion *RabbitMQUpdateVersionSpec `json:"updateVersion,omitempty"`
+	// Specifies information necessary for horizontal scaling
+	HorizontalScaling *RabbitMQHorizontalScalingSpec `json:"horizontalScaling,omitempty"`
 	// Specifies information necessary for vertical scaling
 	VerticalScaling *RabbitMQVerticalScalingSpec `json:"verticalScaling,omitempty"`
 	// Specifies information necessary for volume expansion
 	VolumeExpansion *RabbitMQVolumeExpansionSpec `json:"volumeExpansion,omitempty"`
+	// Specifies information necessary for custom configuration of rabbitmq
+	Configuration *RabbitMQCustomConfigurationSpec `json:"configuration,omitempty"`
+	// Specifies information necessary for configuring TLS
+	TLS *TLSSpec `json:"tls,omitempty"`
 	// Specifies information necessary for restarting database
 	Restart *RestartSpec `json:"restart,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.
@@ -68,14 +76,26 @@ type RabbitMQOpsRequestSpec struct {
 	Apply ApplyOption `json:"apply,omitempty"`
 }
 
-// +kubebuilder:validation:Enum=VerticalScaling;VolumeExpansion;Restart
-// ENUM(VerticalScaling, VolumeExpansion, Restart)
+// +kubebuilder:validation:Enum=UpdateVersion;HorizontalScaling;VerticalScaling;VolumeExpansion;Restart;Reconfigure;ReconfigureTLS
+// ENUM(UpdateVersion, HorizontalScaling, VerticalScaling, VolumeExpansion, Restart, Reconfigure, ReconfigureTLS)
 type RabbitMQOpsRequestType string
 
+// RabbitMQUpdateVersionSpec contains the update version information of a rabbitmq cluster
+type RabbitMQUpdateVersionSpec struct {
+	// Specifies the target version name from catalog
+	TargetVersion string `json:"targetVersion,omitempty"`
+}
+
 // RabbitMQReplicaReadinessCriteria is the criteria for checking readiness of a RabbitMQ pod
 // after updating, horizontal scaling etc.
 type RabbitMQReplicaReadinessCriteria struct{}
 
+// RabbitMQHorizontalScalingSpec contains the horizontal scaling information of a RabbitMQ cluster
+type RabbitMQHorizontalScalingSpec struct {
+	// Number of node
+	Node *int32 `json:"node,omitempty"`
+}
+
 // RabbitMQVerticalScalingSpec contains the vertical scaling information of a RabbitMQ cluster
 type RabbitMQVerticalScalingSpec struct {
 	// Resource spec for nodes
@@ -89,6 +109,27 @@ type RabbitMQVolumeExpansionSpec struct {
 	Node *resource.Quantity `json:"node,omitempty"`
 }
 
+// RabbitMQCustomConfigurationSpec is the spec for Reconfiguring the rabbitmq Settings
+type RabbitMQCustomConfigurationSpec struct {
+	// ConfigSecret is an optional field to provide custom configuration file for database.
+	// +optional
+	ConfigSecret *core.LocalObjectReference `json:"configSecret,omitempty"`
+	// ApplyConfig is an optional field to provide rabbitmq configuration.
+	// Provided configuration will be applied to config files stored in ConfigSecret.
+	// If the ConfigSecret is missing, the operator will create a new k8s secret by the
+	// following naming convention: {db-name}-user-config .
+	// Expected input format:
+	//	applyConfig:
+	//		rabbitmq.conf: |
+	//			key=value
+	// +optional
+	ApplyConfig map[string]string `json:"applyConfig,omitempty"`
+	// If set to "true", the user provided configuration will be removed.
+	// The rabbitmq cluster will start will default configuration that is generated by the operator.
+	// +optional
+	RemoveCustomConfig bool `json:"removeCustomConfig,omitempty"`
+}
+
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // RabbitMQOpsRequestList is a list of RabbitMQOpsRequests