Documentation ¶
Index ¶
- func FixClusterSplit(admin redis.AdminInterface, config *config.Redis, infos *redis.ClusterInfos, ...) (bool, error)
- func FixFailedNodes(admin redis.AdminInterface, cluster *rapi.RedisCluster, ...) (bool, error)
- func FixGhostMasterNodes(admin redis.AdminInterface, podControl pod.RedisClusterControlInteface, ...) (bool, error)
- func FixNodesNotMeet(admin redis.AdminInterface, infos *redis.ClusterInfos, dryRun bool) (bool, error)
- func FixTerminatingPods(cluster *rapi.RedisCluster, podControl pod.RedisClusterControlInteface, ...) (bool, error)
- func FixUntrustedNodes(admin redis.AdminInterface, podControl pod.RedisClusterControlInteface, ...) (bool, error)
- func RunSanityChecks(admin redis.AdminInterface, config *config.Redis, ...) (actionDone bool, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FixClusterSplit ¶
func FixClusterSplit(admin redis.AdminInterface, config *config.Redis, infos *redis.ClusterInfos, dryRun bool) (bool, error)
FixClusterSplit use to detect and fix Cluster split
func FixFailedNodes ¶
func FixFailedNodes(admin redis.AdminInterface, cluster *rapi.RedisCluster, infos *redis.ClusterInfos, dryRun bool) (bool, error)
FixFailedNodes fix failed nodes: in some cases (cluster without enough master after crash or scale down), some nodes may still know about fail nodes
func FixGhostMasterNodes ¶
func FixGhostMasterNodes(admin redis.AdminInterface, podControl pod.RedisClusterControlInteface, cluster *rapi.RedisCluster, info *redis.ClusterInfos) (bool, error)
FixGhostMasterNodes used to removed gost redis nodes
func FixNodesNotMeet ¶
func FixNodesNotMeet(admin redis.AdminInterface, infos *redis.ClusterInfos, dryRun bool) (bool, error)
FixNodesNotMeet Use to fix Redis nodes that didn't them.
func FixTerminatingPods ¶
func FixTerminatingPods(cluster *rapi.RedisCluster, podControl pod.RedisClusterControlInteface, maxDuration time.Duration, dryRun bool) (bool, error)
FixTerminatingPods used to for the deletion of pod blocked in terminating status. in it append the this method will for the deletion of the Pod.
func FixUntrustedNodes ¶
func FixUntrustedNodes(admin redis.AdminInterface, podControl pod.RedisClusterControlInteface, cluster *rapi.RedisCluster, infos *redis.ClusterInfos, dryRun bool) (bool, error)
FixUntrustedNodes used to remove Nodes that are not trusted by other nodes. It can append when a node are removed from the cluster (with the "forget nodes" command) but try to rejoins the cluster.
func RunSanityChecks ¶
func RunSanityChecks(admin redis.AdminInterface, config *config.Redis, podControl pod.RedisClusterControlInteface, cluster *rapi.RedisCluster, infos *redis.ClusterInfos, dryRun bool) (actionDone bool, err error)
RunSanityChecks function used to run all the sanity check on the current cluster Return actionDone = true if a modification has been made on the cluster
Types ¶
This section is empty.