fix typo

streamnative · Nov 7, 2024 · 4b9f052 · 4b9f052
1 parent 938d095
commit 4b9f052
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/coordinator/impl/coordinator.go b/coordinator/impl/coordinator.go
@@ -477,7 +477,7 @@ func (c *coordinator) handleClusterConfigUpdated() error {
 	}
 
 	for _, sc := range c.shardControllers {
-		sc.SyncServerInfo()
+		sc.SyncServerAddress()
 	}
 
 	c.ClusterConfig = newClusterConfig

diff --git a/coordinator/impl/shard_controller.go b/coordinator/impl/shard_controller.go
@@ -64,7 +64,7 @@ type ShardController interface {
 
 	HandleNodeFailure(failedNode model.ServerAddress)
 
-	SyncServerInfo()
+	SyncServerAddress()
 
 	SwapNode(from model.ServerAddress, to model.ServerAddress) error
 	DeleteShard()
@@ -141,7 +141,7 @@ func NewShardController(namespace string, shard int64, namespaceConfig *model.Na
 
 	s.ctx, s.cancel = context.WithCancel(context.Background())
 
-	s.SyncServerInfo()
+	s.SyncServerAddress()
 
 	s.log.Info(
 		"Started shard controller",
@@ -890,7 +890,7 @@ func (s *shardController) waitForFollowersToCatchUp(ctx context.Context, leader
 	return nil
 }
 
-func (s *shardController) SyncServerInfo() {
+func (s *shardController) SyncServerAddress() {
 	s.shardMetadataMutex.RLock()
 	exist := false
 	for _, candidate := range s.shardMetadata.Ensemble {