MB-52930 Populate topologyChange in ShardRebalancer object

Change-Id: Ia7e663b89f7dad86c66b077c8acbb2d55c4c1054
couchbase · Sep 9, 2022 · 6766fd3 · 6766fd3
1 parent ccbefd1
commit 6766fd3
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/secondary/indexer/shard_rebalancer.go b/secondary/indexer/shard_rebalancer.go
@@ -50,6 +50,9 @@ type ShardRebalancer struct {
 	config      c.ConfigHolder
 	retErr      error
 
+	// topologyChange is populated in Rebalance and Failover cases only, else nil
+	topologyChange *service.TopologyChange
+
 	// Metakv management
 	metakvCancel chan struct{}
 	metakvMutex  sync.RWMutex
@@ -92,6 +95,8 @@ func NewShardRebalancer(transferTokens map[string]*c.TransferToken, rebalToken *
 		done:                make(chan struct{}),
 		metakvCancel:        make(chan struct{}),
 		waitForTokenPublish: make(chan struct{}),
+
+		topologyChange: topologyChange,
 	}
 
 	sr.config.Store(config)