Method IsConsistent

export_test.go:63–85

(ctx context.Context)

}

func (c *clusterState) IsConsistent(ctx context.Context) bool {
	if len(c.Masters) < 3 {
		return false
	}
	for _, master := range c.Masters {
		s := master.Client.Info(ctx, "replication").Val()
		if !strings.Contains(s, "role:master") {
			return false
		}
	}

	if len(c.Slaves) < 3 {
		return false
	}
	for _, slave := range c.Slaves {
		s := slave.Client.Info(ctx, "replication").Val()
		if !strings.Contains(s, "role:slave") {
			return false
		}
	}

	return true
}

func GetSlavesAddrByName(ctx context.Context, c *SentinelClient, name string) []string {
	addrs, err := c.Replicas(ctx, name).Result()