manager

Documentation

Index

• func IsdiffAclVerions(curr_map, check_map map[string]string, logger logr.Logger) bool
• type ICheck
  • func NewCheck(client client.Client, logger logr.Logger) ICheck
• type IEnsureResource
  • func NewEnsureResource(client client.Client, logger logr.Logger) IEnsureResource
• type IHeal
  • func NewHealer(heal *heal.CheckAndHeal) IHeal

Functions

func IsdiffAclVerions

func IsdiffAclVerions(curr_map, check_map map[string]string, logger logr.Logger) bool

Types

type ICheck

type ICheck interface {
	CheckRedisNodeNum(*redisv1alpha1.DistributedRedisCluster) error
	//CheckRedisMasterNum(*redisv1alpha1.DistributedRedisCluster) error
	CheckPasswordChanged(*redisv1alpha1.DistributedRedisCluster) (bool, string, map[string]string, error)
}

func NewCheck

func NewCheck(client client.Client, logger logr.Logger) ICheck

type IEnsureResource

type IEnsureResource interface {
	EnsureRedisStatefulsets(cluster *redisv1alpha1.DistributedRedisCluster, labels map[string]string) (bool, error)
	EnsureClusterShardsHeadLessSvcs(cluster *redisv1alpha1.DistributedRedisCluster, labels map[string]string) error
	EnsureClusterHeadLessSvc(cluster *redisv1alpha1.DistributedRedisCluster, labels map[string]string) error
	EnsureRedisConfigMap(cluster *redisv1alpha1.DistributedRedisCluster, labels map[string]string) (error, bool)
	EnsureRedisRCloneSecret(cluster *redisv1alpha1.DistributedRedisCluster, labels map[string]string) error
	UpdateRedisStatefulsets(cluster *redisv1alpha1.DistributedRedisCluster, labels map[string]string) error
}

func NewEnsureResource

func NewEnsureResource(client client.Client, logger logr.Logger) IEnsureResource

type IHeal

type IHeal interface {
	Heal(cluster *redisv1alpha1.DistributedRedisCluster, infos *redisutil.ClusterInfos, admin redisutil.IAdmin, context context.Context) (bool, error)
	FixTerminatingPods(cluster *redisv1alpha1.DistributedRedisCluster, maxDuration time.Duration) (bool, error)
}

func NewHealer

func NewHealer(heal *heal.CheckAndHeal) IHeal