Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Checker ¶
type Checker interface {
GetMasterFromReplication(ctx context.Context, rr *rr.RedisReplication) (corev1.Pod, error)
GetPassword(ctx context.Context, ns string, secret *commonapi.ExistingPasswordSecret) (string, error)
CheckClusterSlotsAssigned(ctx context.Context, cr *rcvb2.RedisCluster) (bool, error)
}
func NewChecker ¶
func NewChecker(clientset kubernetes.Interface) Checker
type Healer ¶
type Healer interface {
SentinelMonitor(ctx context.Context, rs *rsvb2.RedisSentinel, master string) error
// SentinelSet set the config for specific master
// reference: https://redis.io/docs/latest/operate/oss_and_stack/management/sentinel/#reconfiguring-sentinel-at-runtime
SentinelSet(ctx context.Context, rs *rsvb2.RedisSentinel, master string) error
SentinelReset(ctx context.Context, rs *rsvb2.RedisSentinel) error
// UpdatePodRoleLabel connect to all redis pods and update pod role label `redis-role` to `master` or `slave` according to their role.
UpdateRedisRoleLabel(ctx context.Context, ns string, labels map[string]string, secret *commonapi.ExistingPasswordSecret, tlsConfig *commonapi.TLSConfig) error
}
func NewHealer ¶
func NewHealer(clientset kubernetes.Interface) Healer
Click to show internal directories.
Click to hide internal directories.