feat: expose probe in mysqlcluster

CHANGELOG.md

@@ -12,6 +12,7 @@ adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 * `MysqlDatabase` `MysqlUser` Add delete policy
 * Add `PtHeartbeatResources` in `.Spec.PodSpec` to allow the user specifying resources for pt-heartbeat.
 * Set `MysqlCluter.Spec.BackupSchedule` to empty string to disable recurrent backups
+* Add `MySQLLivenessProbe` `MySQLReadinessProbe` `SidecarReadinessProbe` `ExporterLivenessProbe` in `.Spec.PodSpec` to allow the user special probe
 
 ### Changed
 

deploy/charts/mysql-cluster/values.yaml

@@ -19,6 +19,10 @@ appDatabase: ""
 # appSecretAnnotations: {}
 
 podSpec:
+#  mysqlReadinessProbe:
+#  mysqlLivenessProbe:
+#  sidecarReadinessProbe:
+#  exporterLivenessProbe:
 mysqlConf:
 volumeSpec:
 

examples/example-cluster.yaml

@@ -55,6 +55,48 @@ spec:
   #       exec:
   #         command:
   #           - /scripts/demote-if-master
+  #   mysqlReadinessProbe:
+  #     exec:
+  #       command:
+  #         - /bin/sh
+  #         - -c
+  #         - test $(mysql --defaults-file=/etc/mysql/client.conf -NB -e 'SELECT COUNT(*) FROM sys_operator.status WHERE name="configured" AND value="1"') -eq 1
+  #     failureThreshold: 3
+  #     initialDelaySeconds: 5
+  #     periodSeconds: 2
+  #     successThreshold: 1
+  #     timeoutSeconds: 5
+  #   mysqlLivenessProbe:
+  #     exec:
+  #       command:
+  #         - mysqladmin
+  #         - --defaults-file=/etc/mysql/client.conf
+  #         - ping
+  #     failureThreshold: 3
+  #     initialDelaySeconds: 600
+  #     periodSeconds: 5
+  #     successThreshold: 1
+  #     timeoutSeconds: 5
+  #   sidecarReadinessProbe:
+  #     failureThreshold: 3
+  #     httpGet:
+  #       path: /health
+  #       port: 8080
+  #       scheme: HTTP
+  #     initialDelaySeconds: 30
+  #     periodSeconds: 5
+  #     successThreshold: 1
+  #     timeoutSeconds: 5
+  #   exporterLivenessProbe:
+  #     failureThreshold: 3
+  #     httpGet:
+  #       path: /metrics
+  #       port: 9125
+  #       scheme: HTTP
+  #     initialDelaySeconds: 30
+  #     periodSeconds: 30
+  #     successThreshold: 1
+  #     timeoutSeconds: 30
   #   nodeSelector: {}
   #   resources:
   #     requests:

pkg/apis/mysql/v1alpha1/mysqlcluster_types.go

@@ -179,15 +179,19 @@ type PodSpec struct {
 	ImagePullPolicy  core.PullPolicy             `json:"imagePullPolicy,omitempty"`
 	ImagePullSecrets []core.LocalObjectReference `json:"imagePullSecrets,omitempty"`
 
-	Labels             map[string]string         `json:"labels,omitempty"`
-	Annotations        map[string]string         `json:"annotations,omitempty"`
-	Resources          core.ResourceRequirements `json:"resources,omitempty"`
-	Affinity           *core.Affinity            `json:"affinity,omitempty"`
-	MysqlLifecycle     *core.Lifecycle           `json:"mysqlLifecycle,omitempty"`
-	NodeSelector       map[string]string         `json:"nodeSelector,omitempty"`
-	PriorityClassName  string                    `json:"priorityClassName,omitempty"`
-	Tolerations        []core.Toleration         `json:"tolerations,omitempty"`
-	ServiceAccountName string                    `json:"serviceAccountName,omitempty"`
+	Labels                map[string]string         `json:"labels,omitempty"`
+	Annotations           map[string]string         `json:"annotations,omitempty"`
+	Resources             core.ResourceRequirements `json:"resources,omitempty"`
+	Affinity              *core.Affinity            `json:"affinity,omitempty"`
+	MysqlLifecycle        *core.Lifecycle           `json:"mysqlLifecycle,omitempty"`
+	MySQLReadinessProbe   *core.Probe               `json:"mysqlReadinessProbe,omitempty"`
+	MySQLLivenessProbe    *core.Probe               `json:"mysqlLivenessProbe,omitempty"`
+	SidecarReadinessProbe *core.Probe               `json:"sidecarReadinessProbe,omitempty"`
+	ExporterLivenessProbe *core.Probe               `json:"exporterLivenessProbe,omitempty"`
+	NodeSelector          map[string]string         `json:"nodeSelector,omitempty"`
+	PriorityClassName     string                    `json:"priorityClassName,omitempty"`
+	Tolerations           []core.Toleration         `json:"tolerations,omitempty"`
+	ServiceAccountName    string                    `json:"serviceAccountName,omitempty"`
 
 	BackupAffinity          *core.Affinity    `json:"backupAffinity,omitempty"`
 	BackupNodeSelector      map[string]string `json:"backupNodeSelector,omitempty"`

pkg/controller/mysqlcluster/internal/syncer/statefullset.go

@@ -376,15 +376,19 @@ func (s *sfsSyncer) ensureContainersSpec() []core.Container {
 		ContainerPort: MysqlPort,
 	})
 	mysql.Resources = s.ensureResources(containerMysqlName)
-	mysql.LivenessProbe = ensureProbe(60, 5, 5, core.Handler{
-		Exec: &core.ExecAction{
-			Command: []string{
-				"mysqladmin",
-				fmt.Sprintf("--defaults-file=%s", confClientPath),
-				"ping",
+	if probe := s.cluster.Spec.PodSpec.MySQLLivenessProbe; probe == nil {
+		mysql.LivenessProbe = ensureProbe(60, 5, 5, core.Handler{
+			Exec: &core.ExecAction{
+				Command: []string{
+					"mysqladmin",
+					fmt.Sprintf("--defaults-file=%s", confClientPath),
+					"ping",
+				},
 			},
-		},
-	})
+		})
+	} else {
+		mysql.LivenessProbe = probe
+	}
 
 	// set lifecycle hook on MySQL container
 	if s.cluster.Spec.PodSpec.MysqlLifecycle != nil {
@@ -404,14 +408,18 @@ func (s *sfsSyncer) ensureContainersSpec() []core.Container {
 		confClientPath, constants.OperatorDbName, constants.OperatorStatusTableName)
 
 	// we have to know ASAP when server is not ready to remove it from endpoints
-	mysql.ReadinessProbe = ensureProbe(5, 5, 2, core.Handler{
-		Exec: &core.ExecAction{
-			Command: []string{
-				"/bin/sh", "-c",
-				fmt.Sprintf(`test $(%s) -eq 1`, mysqlTestCmd),
+	if probe := s.cluster.Spec.PodSpec.MySQLReadinessProbe; probe == nil {
+		mysql.ReadinessProbe = ensureProbe(5, 5, 2, core.Handler{
+			Exec: &core.ExecAction{
+				Command: []string{
+					"/bin/sh", "-c",
+					fmt.Sprintf(`test $(%s) -eq 1`, mysqlTestCmd),
+				},
 			},
-		},
-	})
+		})
+	} else {
+		mysql.ReadinessProbe = probe
+	}
 
 	// SIDECAR container
 	sidecar := s.ensureContainer(containerSidecarName,
@@ -423,13 +431,17 @@ func (s *sfsSyncer) ensureContainersSpec() []core.Container {
 		ContainerPort: SidecarServerPort,
 	})
 	sidecar.Resources = s.ensureResources(containerSidecarName)
-	sidecar.ReadinessProbe = ensureProbe(30, 5, 5, core.Handler{
-		HTTPGet: &core.HTTPGetAction{
-			Path:   SidecarServerProbePath,
-			Port:   intstr.FromInt(SidecarServerPort),
-			Scheme: core.URISchemeHTTP,
-		},
-	})
+	if probe := s.cluster.Spec.PodSpec.SidecarReadinessProbe; probe == nil {
+		sidecar.ReadinessProbe = ensureProbe(30, 5, 5, core.Handler{
+			HTTPGet: &core.HTTPGetAction{
+				Path:   SidecarServerProbePath,
+				Port:   intstr.FromInt(SidecarServerPort),
+				Scheme: core.URISchemeHTTP,
+			},
+		})
+	} else {
+		sidecar.ReadinessProbe = probe
+	}
 
 	// METRICS container
 	exporterCommand := []string{
@@ -455,13 +467,17 @@ func (s *sfsSyncer) ensureContainersSpec() []core.Container {
 
 	exporter.Resources = s.ensureResources(containerExporterName)
 
-	exporter.LivenessProbe = ensureProbe(30, 30, 30, core.Handler{
-		HTTPGet: &core.HTTPGetAction{
-			Path:   ExporterPath,
-			Port:   ExporterTargetPort,
-			Scheme: core.URISchemeHTTP,
-		},
-	})
+	if probe := s.cluster.Spec.PodSpec.ExporterLivenessProbe; probe == nil {
+		exporter.LivenessProbe = ensureProbe(30, 30, 30, core.Handler{
+			HTTPGet: &core.HTTPGetAction{
+				Path:   ExporterPath,
+				Port:   ExporterTargetPort,
+				Scheme: core.URISchemeHTTP,
+			},
+		})
+	} else {
+		exporter.LivenessProbe = probe
+	}
 
 	// PT-HEARTBEAT container
 	heartbeat := s.ensureContainer(containerHeartBeatName,