Versions in this module Expand all Collapse all v1 v1.0.2 Jul 27, 2021 Changes in this version + func GetRedisName(rf *redisfailoverv1.RedisFailover) string + func GetRedisReadinessName(rf *redisfailoverv1.RedisFailover) string + func GetRedisShutdownConfigMapName(rf *redisfailoverv1.RedisFailover) string + func GetRedisShutdownName(rf *redisfailoverv1.RedisFailover) string + func GetSentinelName(rf *redisfailoverv1.RedisFailover) string + type RedisFailoverCheck interface + CheckAllSlavesFromMaster func(master string, rFailover *redisfailoverv1.RedisFailover) error + CheckRedisNumber func(rFailover *redisfailoverv1.RedisFailover) error + CheckRedisSlavesReady func(slaveIP string, rFailover *redisfailoverv1.RedisFailover) (bool, error) + CheckSentinelMonitor func(sentinel string, monitor ...string) error + CheckSentinelNumber func(rFailover *redisfailoverv1.RedisFailover) error + CheckSentinelNumberInMemory func(sentinel string, rFailover *redisfailoverv1.RedisFailover) error + CheckSentinelSlavesNumberInMemory func(sentinel string, rFailover *redisfailoverv1.RedisFailover) error + GetMasterIP func(rFailover *redisfailoverv1.RedisFailover) (string, error) + GetMinimumRedisPodTime func(rFailover *redisfailoverv1.RedisFailover) (time.Duration, error) + GetNumberMasters func(rFailover *redisfailoverv1.RedisFailover) (int, error) + GetRedisRevisionHash func(podName string, rFailover *redisfailoverv1.RedisFailover) (string, error) + GetRedisesIPs func(rFailover *redisfailoverv1.RedisFailover) ([]string, error) + GetRedisesMasterPod func(rFailover *redisfailoverv1.RedisFailover) (string, error) + GetRedisesSlavesPods func(rFailover *redisfailoverv1.RedisFailover) ([]string, error) + GetSentinelsIPs func(rFailover *redisfailoverv1.RedisFailover) ([]string, error) + GetStatefulSetUpdateRevision func(rFailover *redisfailoverv1.RedisFailover) (string, error) + type RedisFailoverChecker struct + func NewRedisFailoverChecker(k8sService k8s.Services, redisClient redis.Client, logger log.Logger) *RedisFailoverChecker + func (r *RedisFailoverChecker) CheckAllSlavesFromMaster(master string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverChecker) CheckRedisNumber(rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverChecker) CheckRedisSlavesReady(ip string, rFailover *redisfailoverv1.RedisFailover) (bool, error) + func (r *RedisFailoverChecker) CheckSentinelMonitor(sentinel string, monitor ...string) error + func (r *RedisFailoverChecker) CheckSentinelNumber(rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverChecker) CheckSentinelNumberInMemory(sentinel string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverChecker) CheckSentinelSlavesNumberInMemory(sentinel string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverChecker) GetMasterIP(rf *redisfailoverv1.RedisFailover) (string, error) + func (r *RedisFailoverChecker) GetMinimumRedisPodTime(rf *redisfailoverv1.RedisFailover) (time.Duration, error) + func (r *RedisFailoverChecker) GetNumberMasters(rf *redisfailoverv1.RedisFailover) (int, error) + func (r *RedisFailoverChecker) GetRedisRevisionHash(podName string, rFailover *redisfailoverv1.RedisFailover) (string, error) + func (r *RedisFailoverChecker) GetRedisesIPs(rf *redisfailoverv1.RedisFailover) ([]string, error) + func (r *RedisFailoverChecker) GetRedisesMasterPod(rFailover *redisfailoverv1.RedisFailover) (string, error) + func (r *RedisFailoverChecker) GetRedisesSlavesPods(rf *redisfailoverv1.RedisFailover) ([]string, error) + func (r *RedisFailoverChecker) GetSentinelsIPs(rf *redisfailoverv1.RedisFailover) ([]string, error) + func (r *RedisFailoverChecker) GetStatefulSetUpdateRevision(rFailover *redisfailoverv1.RedisFailover) (string, error) + type RedisFailoverClient interface + EnsureNotPresentRedisService func(rFailover *redisfailoverv1.RedisFailover) error + EnsureRedisConfigMap func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureRedisReadinessConfigMap func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureRedisService func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureRedisShutdownConfigMap func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureRedisStatefulset func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureSentinelConfigMap func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureSentinelDeployment func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + EnsureSentinelService func(rFailover *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + type RedisFailoverHeal interface + DeletePod func(podName string, rFailover *redisfailoverv1.RedisFailover) error + MakeMaster func(ip string, rFailover *redisfailoverv1.RedisFailover) error + NewSentinelMonitor func(ip string, monitor string, rFailover *redisfailoverv1.RedisFailover) error + NewSentinelMonitorWithPort func(ip string, monitor string, port string, ...) error + RestoreSentinel func(ip string) error + SetExternalMasterOnAll func(masterIP string, masterPort string, rFailover *redisfailoverv1.RedisFailover) error + SetMasterOnAll func(masterIP string, rFailover *redisfailoverv1.RedisFailover) error + SetOldestAsMaster func(rFailover *redisfailoverv1.RedisFailover) error + SetRedisCustomConfig func(ip string, rFailover *redisfailoverv1.RedisFailover) error + SetSentinelCustomConfig func(ip string, rFailover *redisfailoverv1.RedisFailover) error + type RedisFailoverHealer struct + func NewRedisFailoverHealer(k8sService k8s.Services, redisClient redis.Client, logger log.Logger) *RedisFailoverHealer + func (r *RedisFailoverHealer) DeletePod(podName string, rFailover *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) MakeMaster(ip string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) NewSentinelMonitor(ip string, monitor string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) NewSentinelMonitorWithPort(ip string, monitor string, monitorPort string, ...) error + func (r *RedisFailoverHealer) RestoreSentinel(ip string) error + func (r *RedisFailoverHealer) SetExternalMasterOnAll(masterIP, masterPort string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) SetMasterOnAll(masterIP string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) SetOldestAsMaster(rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) SetRedisCustomConfig(ip string, rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverHealer) SetSentinelCustomConfig(ip string, rf *redisfailoverv1.RedisFailover) error + type RedisFailoverKubeClient struct + K8SService k8s.Services + func NewRedisFailoverKubeClient(k8sService k8s.Services, logger log.Logger) *RedisFailoverKubeClient + func (r *RedisFailoverKubeClient) EnsureNotPresentRedisService(rf *redisfailoverv1.RedisFailover) error + func (r *RedisFailoverKubeClient) EnsureRedisConfigMap(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureRedisReadinessConfigMap(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureRedisService(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureRedisShutdownConfigMap(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureRedisStatefulset(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureSentinelConfigMap(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureSentinelDeployment(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error + func (r *RedisFailoverKubeClient) EnsureSentinelService(rf *redisfailoverv1.RedisFailover, labels map[string]string, ...) error