shard DDL: rewrite shard DDL in pessimism mode for HA (pingcap#456)

lichunzhu · Feb 11, 2020 · 2a8a594 · 2a8a594
1 parent 7135428
commit 2a8a594
Show file tree

Hide file tree

Showing 54 changed files with 2,657 additions and 3,954 deletions.
diff --git a/cmd/dm-syncer/main.go b/cmd/dm-syncer/main.go
@@ -63,7 +63,7 @@ func main() {
 		log.L().Info("", zap.Stringer("dm-syncer conf", conf))
 	})
 
-	sync := syncer.NewSyncer(conf)
+	sync := syncer.NewSyncer(conf, nil) // do not support shard DDL for singleton syncer.
 	sc := make(chan os.Signal, 1)
 	signal.Notify(sc, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)
 

diff --git a/dm/common/common.go b/dm/common/common.go
@@ -39,6 +39,13 @@ var (
 	// UpstreamSubTaskKeyAdapter used to store SubTask which are subscribing data from MySQL source.
 	// k/v: Encode(source-id, task-name) -> SubTaskConfig
 	UpstreamSubTaskKeyAdapter KeyAdapter = keyHexEncoderDecoder("/dm-master/upstream/subtask/")
+
+	// ShardDDLPessimismInfoKeyAdapter used to store shard DDL info in pessimistic model.
+	// k/v: Encode(task-name, source-id) -> shard DDL info
+	ShardDDLPessimismInfoKeyAdapter KeyAdapter = keyHexEncoderDecoder("/dm-master/shardddl-pessimism/info/")
+	// ShardDDLPessimismOperationKeyAdapter used to store shard DDL lock in pessimistic model.
+	// k/v: Encode(task-name, source-id) -> shard DDL operation
+	ShardDDLPessimismOperationKeyAdapter KeyAdapter = keyHexEncoderDecoder("/dm-master/shardddl-pessimism/operation/")
 )
 
 func keyAdapterKeysLen(s KeyAdapter) int {