Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ICheck ¶
type ICheck interface {
CheckRedisNodeNum(*redisv1alpha1.DistributedRedisCluster) error
//CheckRedisMasterNum(*redisv1alpha1.DistributedRedisCluster) error
CheckPasswordChanged(*redisv1alpha1.DistributedRedisCluster) (bool, string, map[string]string, error)
}
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
Click to show internal directories.
Click to hide internal directories.