*: add leader to follower choice

radondb · Oct 26, 2023 · 2e20c17 · 2e20c17
1 parent 62a7e0f
commit 2e20c17
Show file tree

Hide file tree

Showing 6 changed files with 36 additions and 1 deletion.
diff --git a/api/v1alpha1/mysqlcluster_types.go b/api/v1alpha1/mysqlcluster_types.go
@@ -117,6 +117,11 @@ type MysqlClusterSpec struct {
 	// Bootstraping from remote data source
 	// +optional
 	SourceConfig *corev1.SecretProjection `json:"sourceConfig,omitempty"`
+
+	// Leader as follower represents if make leader use as follower to read
+	// +optional
+	// +kubebuilder:default:=false
+	LeaderAsFollower bool `json:"leaderAsfollower,omitempty"`
 }
 
 // ReadOnly define the ReadOnly pods

diff --git a/api/v1beta1/mysqlcluster_types.go b/api/v1beta1/mysqlcluster_types.go
@@ -149,6 +149,11 @@ type MysqlClusterSpec struct {
 	// Specification of the service that exposes the MySQL leader instance.
 	// +optional
 	Service *ServiceSpec `json:"service,omitempty"`
+
+	// Leader as follower represents if make leader use as follower to read
+	// +optional
+	// +kubebuilder:default:=false
+	LeaderAsFollower bool `json:"leaderAsfollower,omitempty"`
 }
 
 // ReadOnly define the ReadOnly pods

diff --git a/api/v1beta1/zz_generated.conversion.go b/api/v1beta1/zz_generated.conversion.go
diff --git a/charts/mysql-operator/templates/mysql.radondb.com_mysqlclusters.yaml b/charts/mysql-operator/templates/mysql.radondb.com_mysqlclusters.yaml
@@ -101,6 +101,11 @@ spec:
                 description: Lagged
                 format: int32
                 type: integer
+              leaderAsfollower:
+                default: false
+                description: Leader as follower represents if make leader use as follower
+                  to read
+                type: boolean
               metricsOpts:
                 default:
                   enabled: false
@@ -3598,6 +3603,11 @@ spec:
                 description: Lagged
                 format: int32
                 type: integer
+              leaderAsfollower:
+                default: false
+                description: Leader as follower represents if make leader use as follower
+                  to read
+                type: boolean
               logOpts:
                 description: LogOpts is the options of log settings.
                 properties:

diff --git a/config/crd/bases/mysql.radondb.com_mysqlclusters.yaml b/config/crd/bases/mysql.radondb.com_mysqlclusters.yaml
@@ -83,6 +83,11 @@ spec:
                 description: Lagged
                 format: int32
                 type: integer
+              leaderAsfollower:
+                default: false
+                description: Leader as follower represents if make leader use as follower
+                  to read
+                type: boolean
               metricsOpts:
                 default:
                   enabled: false
@@ -3580,6 +3585,11 @@ spec:
                 description: Lagged
                 format: int32
                 type: integer
+              leaderAsfollower:
+                default: false
+                description: Leader as follower represents if make leader use as follower
+                  to read
+                type: boolean
               logOpts:
                 description: LogOpts is the options of log settings.
                 properties:

diff --git a/mysqlcluster/syncer/follower_service.go b/mysqlcluster/syncer/follower_service.go
@@ -48,7 +48,10 @@ func NewFollowerSVCSyncer(cli client.Client, c *mysqlcluster.MysqlCluster) synce
 			service.Spec.Type = "ClusterIP"
 		}
 		service.Spec.Selector = c.GetSelectorLabels()
-		service.Spec.Selector["role"] = string(utils.Follower)
+
+		if !c.Spec.LeaderAsFollower {
+			service.Spec.Selector["role"] = string(utils.Follower)
+		}
 		service.Spec.Selector["healthy"] = "yes"
 
 		if len(service.Spec.Ports) != 2 {