service

package

Go to main page

Versions in this module

v1

v1.3.0-rc1

Aug 21, 2023

v1.2.4

Dec 28, 2022

Changes in this version

type RedisFailoverCheck

+ CheckIfMasterLocalhost func(rFailover *redisfailoverv1.RedisFailover) (bool, error)

+ CheckSentinelQuorum func(rFailover *redisfailoverv1.RedisFailover) (int, error)

+ GetMaxRedisPodTime func(rFailover *redisfailoverv1.RedisFailover) (time.Duration, error)

type RedisFailoverChecker

+ func (r *RedisFailoverChecker) CheckIfMasterLocalhost(rFailover *redisfailoverv1.RedisFailover) (bool, error)

+ func (r *RedisFailoverChecker) CheckSentinelQuorum(rFailover *redisfailoverv1.RedisFailover) (int, error)

+ func (r *RedisFailoverChecker) GetMaxRedisPodTime(rf *redisfailoverv1.RedisFailover) (time.Duration, error)

v1.2.3

Dec 1, 2022

Changes in this version

+ func AreAllRunning(pods *corev1.PodList) bool

type RedisFailoverCheck

+ IsClusterRunning func(rFailover *redisfailoverv1.RedisFailover) bool

+ IsRedisRunning func(rFailover *redisfailoverv1.RedisFailover) bool

+ IsSentinelRunning func(rFailover *redisfailoverv1.RedisFailover) bool

type RedisFailoverChecker

+ func (r *RedisFailoverChecker) IsClusterRunning(rFailover *redisfailoverv1.RedisFailover) bool

+ func (r *RedisFailoverChecker) IsRedisRunning(rFailover *redisfailoverv1.RedisFailover) bool

+ func (r *RedisFailoverChecker) IsSentinelRunning(rFailover *redisfailoverv1.RedisFailover) bool

v1.2.2

Oct 21, 2022

v1.2.1

Sep 15, 2022

v1.2.0

Sep 8, 2022

v1.2.0-rc1

Sep 6, 2022

v1.2.0-rc0

Aug 31, 2022

v1.1.1

Feb 7, 2022

v1.1.0

Jan 24, 2022

Changes in this version

type RedisFailoverHeal

+ NewSentinelMonitorWithPort func(ip string, monitor string, port string, ...) error

+ SetExternalMasterOnAll func(masterIP string, masterPort string, rFailover *redisfailoverv1.RedisFailover) error

type RedisFailoverHealer

+ func (r *RedisFailoverHealer) NewSentinelMonitorWithPort(ip string, monitor string, monitorPort string, ...) error

+ func (r *RedisFailoverHealer) SetExternalMasterOnAll(masterIP, masterPort string, rf *redisfailoverv1.RedisFailover) error

v1.1.0-rc.3

Jan 19, 2022

v1.1.0-rc.2

Jan 17, 2022

v1.1.0-rc.1

Jan 12, 2022

v1.0.0

Feb 24, 2020

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

+ RestoreSentinel func(ip string) 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) RestoreSentinel(ip string) 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

v1.0.0-rc.5

Feb 7, 2020

v1.0.0-rc.4

Dec 17, 2019

v1.0.0-rc.3

Dec 11, 2019

v1.0.0-rc.2

Nov 15, 2019

v1.0.0-rc.1

May 10, 2019

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL