fix: Fix the issue where Sentinel fails to monitor one replica replication (#1481)

* fix: Solve the issue where Sentinel fails to work when starting 1 Master Replication

Signed-off-by: tcxdgit <[email protected]>

* fix: Fix failure to get monitorAddr in reconcileSentinel for single instance

Signed-off-by: tcxdgit <[email protected]>

---------

Signed-off-by: tcxdgit <[email protected]>

Author: tcxdgit

internal/controller/common/redis/check.go

@@ -91,6 +91,12 @@ func (c *checker) GetMasterFromReplication(ctx context.Context, rr *rr.RedisRepl
 		if count != 0 {
 			realMasterPod = pod
 			break
+		} else {
+			replicaNum := *sts.Spec.Replicas
+			if replicaNum == 1 {
+				realMasterPod = pod
+				break
+			}
 		}
 	}
 	return realMasterPod, nil

internal/k8sutils/redis-sentinel.go

@@ -340,15 +340,23 @@ func getRedisReplicationMasterPod(ctx context.Context, client kubernetes.Interfa
 		log.FromContext(ctx).Error(errors.New("no master pods found"), "")
 		return emptyRedisInfo
 	}
-	for _, podName := range masterPods {
-		redisClient := configureRedisReplicationClient(ctx, client, &replicationInstance, podName)
-		defer redisClient.Close()
 
-		if checkAttachedSlave(ctx, redisClient, podName) > 0 {
-			realMasterPod = podName
-			break
+	replicasNum := *cr.Spec.Size
+
+	if replicasNum == 1 {
+		realMasterPod = masterPods[0]
+	} else {
+		for _, podName := range masterPods {
+			redisClient := configureRedisReplicationClient(ctx, client, &replicationInstance, podName)
+			defer redisClient.Close()
+
+			if checkAttachedSlave(ctx, redisClient, podName) > 0 {
+				realMasterPod = podName
+				break
+			}
 		}
 	}
+
 	if realMasterPod == "" {
 		log.FromContext(ctx).Error(errors.New("no real master pod found"), "")
 		return emptyRedisInfo