heal

Documentation

Index

• type CheckAndHeal
  • func (c *CheckAndHeal) FixClusterSplit(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, ...) (bool, error)
  • func (c *CheckAndHeal) FixFailedNodes(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, ...) (bool, error)
  • func (c *CheckAndHeal) FixTerminatingPods(cluster *redisv1alpha1.DistributedRedisCluster, maxDuration time.Duration) (bool, error)
  • func (c *CheckAndHeal) FixUntrustedNodes(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, ...) (bool, error)

Types

type CheckAndHeal

type CheckAndHeal struct {
	Logger     logr.Logger
	PodControl k8sutil.IPodControl
	Pods       []*corev1.Pod
	DryRun     bool
}

func (*CheckAndHeal) FixClusterSplit

func (c *CheckAndHeal) FixClusterSplit(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, admin redisutil.IAdmin, config *config.Redis) (bool, error)

FixClusterSplit use to detect and fix Cluster split

func (*CheckAndHeal) FixFailedNodes

func (c *CheckAndHeal) FixFailedNodes(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, admin redisutil.IAdmin) (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 (*CheckAndHeal) FixTerminatingPods

func (c *CheckAndHeal) FixTerminatingPods(cluster *redisv1alpha1.DistributedRedisCluster, maxDuration time.Duration) (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 (*CheckAndHeal) FixUntrustedNodes

func (c *CheckAndHeal) FixUntrustedNodes(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, admin redisutil.IAdmin) (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.