deploy controller for tiflash (#2157)

pingcap · Apr 13, 2020 · fa43ad1 · fa43ad1
1 parent 782a1aa
commit fa43ad1
Show file tree

Hide file tree

Showing 24 changed files with 2,497 additions and 745 deletions.
diff --git a/charts/tidb-operator/templates/controller-manager-deployment.yaml b/charts/tidb-operator/templates/controller-manager-deployment.yaml
@@ -46,6 +46,7 @@ spec:
          {{- end }}
           - -pd-failover-period={{ .Values.controllerManager.pdFailoverPeriod | default "5m" }}
           - -tikv-failover-period={{ .Values.controllerManager.tikvFailoverPeriod | default "5m" }}
+          - -tiflash-failover-period={{ .Values.controllerManager.tiflashFailoverPeriod | default "5m" }}
           - -tidb-failover-period={{ .Values.controllerManager.tidbFailoverPeriod | default "5m" }}
           - -v={{ .Values.controllerManager.logLevel }}
           {{- if .Values.testMode }}

diff --git a/charts/tidb-operator/values.yaml b/charts/tidb-operator/values.yaml
@@ -58,6 +58,8 @@ controllerManager:
   tikvFailoverPeriod: 5m
   # tidb failover period default(5m)
   tidbFailoverPeriod: 5m
+  # tiflash failover period default(5m)
+  tiflashFailoverPeriod: 5m
   ## affinity defines pod scheduling rules,affinity default settings is empty.
   ## please read the affinity document before set your scheduling rule:
   ## ref: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/#affinity-and-anti-affinity

diff --git a/cmd/controller-manager/main.go b/cmd/controller-manager/main.go
@@ -52,16 +52,17 @@ import (
 )
 
 var (
-	printVersion       bool
-	workers            int
-	autoFailover       bool
-	pdFailoverPeriod   time.Duration
-	tikvFailoverPeriod time.Duration
-	tidbFailoverPeriod time.Duration
-	leaseDuration      = 15 * time.Second
-	renewDuration      = 5 * time.Second
-	retryPeriod        = 3 * time.Second
-	waitDuration       = 5 * time.Second
+	printVersion          bool
+	workers               int
+	autoFailover          bool
+	pdFailoverPeriod      time.Duration
+	tikvFailoverPeriod    time.Duration
+	tidbFailoverPeriod    time.Duration
+	tiflashFailoverPeriod time.Duration
+	leaseDuration         = 15 * time.Second
+	renewDuration         = 5 * time.Second
+	retryPeriod           = 3 * time.Second
+	waitDuration          = 5 * time.Second
 )
 
 func init() {
@@ -72,6 +73,7 @@ func init() {
 	flag.BoolVar(&autoFailover, "auto-failover", true, "Auto failover")
 	flag.DurationVar(&pdFailoverPeriod, "pd-failover-period", time.Duration(5*time.Minute), "PD failover period default(5m)")
 	flag.DurationVar(&tikvFailoverPeriod, "tikv-failover-period", time.Duration(5*time.Minute), "TiKV failover period default(5m)")
+	flag.DurationVar(&tiflashFailoverPeriod, "tiflash-failover-period", time.Duration(5*time.Minute), "TiFlash failover period default(5m)")
 	flag.DurationVar(&tidbFailoverPeriod, "tidb-failover-period", time.Duration(5*time.Minute), "TiDB failover period")
 	flag.DurationVar(&controller.ResyncDuration, "resync-duration", time.Duration(30*time.Second), "Resync time of informer")
 	flag.BoolVar(&controller.TestMode, "test-mode", false, "whether tidb-operator run in test mode")
@@ -179,7 +181,7 @@ func main() {
 			klog.Fatalf("failed to upgrade: %v", err)
 		}
 
-		tcController := tidbcluster.NewController(kubeCli, cli, genericCli, informerFactory, kubeInformerFactory, autoFailover, pdFailoverPeriod, tikvFailoverPeriod, tidbFailoverPeriod)
+		tcController := tidbcluster.NewController(kubeCli, cli, genericCli, informerFactory, kubeInformerFactory, autoFailover, pdFailoverPeriod, tikvFailoverPeriod, tidbFailoverPeriod, tiflashFailoverPeriod)
 		backupController := backup.NewController(kubeCli, cli, informerFactory, kubeInformerFactory)
 		restoreController := restore.NewController(kubeCli, cli, informerFactory, kubeInformerFactory)
 		bsController := backupschedule.NewController(kubeCli, cli, informerFactory, kubeInformerFactory)

diff --git a/docs/api-references/config.json b/docs/api-references/config.json
@@ -9,12 +9,13 @@
     "TCPPort",
     "HTTPPort",
     "InternalServerHTTPPort",
-    "Errorlog",
+    "ErrorLog",
     "ServerLog",
     "TiDBStatusAddr",
     "ServiceAddr",
     "ProxyConfig",
     "ClusterManagerPath",
+    "Flash",
     "FlashStatus",
     "FlashQuota",
     "FlashUser",
@@ -27,7 +28,18 @@
   "hideTypePatterns": [
     "ParseError$",
     "List$",
-    "DataResource"
+    "DataResource",
+    "ProxyConfig",
+    "^Flash$",
+    "FlashCluster",
+    "FlashStatus",
+    "FlashQuota",
+    "FlashUser",
+    "FlashProfile",
+    "FlashApplication",
+    "FlashProxy",
+    "FlashServerConfig",
+    "FlashRaft"
   ],
   "externalPackages": [
     {