fix: for cluster node, when prefer_replica set to true can not get be…

…st replica (#841)
tair-opensource · Jul 12, 2024 · 5c11f28 · 5c11f28
1 parent 040c64f
commit 5c11f28
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/client/redis.go b/internal/client/redis.go
@@ -77,6 +77,10 @@ func NewRedisClient(ctx context.Context, address string, username string, passwo
 	// get best replica
 	if replica {
 		replicaInfo := getReplicaAddr(reply)
+		// slave node return BestReplica is none，set value by address
+		if replicaInfo.BestReplica == "" {
+			replicaInfo.BestReplica = address
+		}
 		log.Infof("best replica: %s", replicaInfo.BestReplica)
 		r = NewRedisClient(ctx, replicaInfo.BestReplica, username, password, Tls, false)
 	}