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.