add deploy mode

apache · Oct 7, 2023 · 52b8f67 · 52b8f67
1 parent 7974b6b
commit 52b8f67
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/server/coordinator/scheduler/reopen_shard_scheduler.go b/server/coordinator/scheduler/reopen_shard_scheduler.go
@@ -27,6 +27,10 @@ func NewReopenShardScheduler(factory *coordinator.Factory, procedureExecutingBat
 	}
 }
 
+func (r ReopenShardScheduler) UpdateDeployMode(_ context.Context, _ bool) {
+	// ReopenShardScheduler do not need deployMode.
+}
+
 func (r ReopenShardScheduler) Schedule(ctx context.Context, clusterSnapshot metadata.Snapshot) (ScheduleResult, error) {
 	// ReopenShardScheduler can only be scheduled when the cluster is stable.
 	if !clusterSnapshot.Topology.IsStable() {

diff --git a/server/coordinator/scheduler/static_topology_shard_scheduler.go b/server/coordinator/scheduler/static_topology_shard_scheduler.go
@@ -25,6 +25,10 @@ func NewStaticTopologyShardScheduler(factory *coordinator.Factory, nodePicker co
 	return StaticTopologyShardScheduler{factory: factory, nodePicker: nodePicker, procedureExecutingBatchSize: procedureExecutingBatchSize}
 }
 
+func (s StaticTopologyShardScheduler) UpdateDeployMode(_ context.Context, _ bool) {
+	// StaticTopologyShardScheduler do not need deployMode.
+}
+
 func (s StaticTopologyShardScheduler) Schedule(ctx context.Context, clusterSnapshot metadata.Snapshot) (ScheduleResult, error) {
 	var procedures []procedure.Procedure
 	var reasons strings.Builder