Function countUsableReplicas

sentinel_test.go:706–721

countUsableReplicas mirrors the filter applied by parseReplicaAddrs in sentinel.go: a replica is usable only when it is not s_down, o_down, or disconnected. Plain len() on Sentinel's Replicas reply is not enough — post-failover, replicas often linger with the "disconnected" flag for several seconds

(replicas []map[string]string)

// usable list and silently fall back to the master (see RandomReplicaAddr
// in sentinel.go).
func countUsableReplicas(replicas []map[string]string) int {
	usable := 0
	for _, node := range replicas {
		down := false
		for _, flag := range strings.Split(node["flags"], ",") {
			switch flag {
			case "s_down", "o_down", "disconnected":
				down = true
			}
		}
		if !down && node["ip"] != "" && node["port"] != "" {
			usable++
		}
	}
	return usable
}

func waitForSentinelClusterStable() {
	sentinel1 := redis.NewSentinelClient(&redis.Options{