Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

service

package

Go to main page

Versions in this module

v0

v0.1.7

Jan 20, 2020

v0.1.6

Dec 17, 2019

v0.1.4

Nov 29, 2019

Changes in this version

+ type RedisClusterCheck interface

+ CheckAllSlavesFromMaster func(master string, redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ CheckRedisConfig func(redisCluster *redisv1beta1.RedisCluster, addr string, auth *util.AuthConfig) error

+ CheckRedisNumber func(redisCluster *redisv1beta1.RedisCluster) error

+ CheckSentinelMonitor func(sentinel string, monitor string, auth *util.AuthConfig) error

+ CheckSentinelNumber func(redisCluster *redisv1beta1.RedisCluster) error

+ CheckSentinelNumberInMemory func(sentinel string, redisCluster *redisv1beta1.RedisCluster, ...) error

+ CheckSentinelReadyReplicas func(redisCluster *redisv1beta1.RedisCluster) error

+ CheckSentinelSlavesNumberInMemory func(sentinel string, redisCluster *redisv1beta1.RedisCluster, ...) error

+ GetMasterIP func(redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) (string, error)

+ GetMinimumRedisPodTime func(redisCluster *redisv1beta1.RedisCluster) (time.Duration, error)

+ GetNumberMasters func(redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) (int, error)

+ GetRedisesIPs func(redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) ([]string, error)

+ GetSentinelsIPs func(redisCluster *redisv1beta1.RedisCluster) ([]string, error)

+ type RedisClusterChecker struct

+ func NewRedisClusterChecker(k8sService k8s.Services, redisClient redis.Client, logger logr.Logger) *RedisClusterChecker

+ func (r *RedisClusterChecker) CheckAllSlavesFromMaster(master string, rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ func (r *RedisClusterChecker) CheckRedisConfig(redisCluster *redisv1beta1.RedisCluster, addr string, auth *util.AuthConfig) error

+ func (r *RedisClusterChecker) CheckRedisNumber(rc *redisv1beta1.RedisCluster) error

+ func (r *RedisClusterChecker) CheckSentinelMonitor(sentinel string, monitor string, auth *util.AuthConfig) error

+ func (r *RedisClusterChecker) CheckSentinelNumber(rc *redisv1beta1.RedisCluster) error

+ func (r *RedisClusterChecker) CheckSentinelNumberInMemory(sentinel string, rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ func (r *RedisClusterChecker) CheckSentinelReadyReplicas(rc *redisv1beta1.RedisCluster) error

+ func (r *RedisClusterChecker) CheckSentinelSlavesNumberInMemory(sentinel string, rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ func (r *RedisClusterChecker) GetMasterIP(rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) (string, error)

+ func (r *RedisClusterChecker) GetMinimumRedisPodTime(rc *redisv1beta1.RedisCluster) (time.Duration, error)

+ func (r *RedisClusterChecker) GetNumberMasters(rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) (int, error)

+ func (r *RedisClusterChecker) GetRedisesIPs(rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) ([]string, error)

+ func (r *RedisClusterChecker) GetSentinelsIPs(rc *redisv1beta1.RedisCluster) ([]string, error)

+ type RedisClusterClient interface

+ EnsureNotPresentRedisService func(redisCluster *redisv1beta1.RedisCluster) error

+ EnsureRedisConfigMap func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureRedisService func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureRedisShutdownConfigMap func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureRedisStatefulset func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureSentinelConfigMap func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureSentinelHeadlessService func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureSentinelProbeConfigMap func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureSentinelService func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ EnsureSentinelStatefulset func(redisCluster *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ type RedisClusterHeal interface

+ MakeMaster func(ip string, auth *util.AuthConfig) error

+ NewSentinelMonitor func(ip string, monitor string, redisCluster *redisv1beta1.RedisCluster, ...) error

+ RestoreSentinel func(ip string, auth *util.AuthConfig) error

+ SetMasterOnAll func(masterIP string, redisCluster *redisv1beta1.RedisCluster, ...) error

+ SetOldestAsMaster func(redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ SetRedisCustomConfig func(ip string, redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ SetSentinelCustomConfig func(ip string, redisCluster *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ type RedisClusterHealer struct

+ func NewRedisClusterHealer(k8sService k8s.Services, redisClient redis.Client, logger logr.Logger) *RedisClusterHealer

+ func (r *RedisClusterHealer) MakeMaster(ip string, auth *util.AuthConfig) error

+ func (r *RedisClusterHealer) NewSentinelMonitor(ip string, monitor string, rc *redisv1beta1.RedisCluster, ...) error

+ func (r *RedisClusterHealer) RestoreSentinel(ip string, auth *util.AuthConfig) error

+ func (r *RedisClusterHealer) SetMasterOnAll(masterIP string, rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ func (r *RedisClusterHealer) SetOldestAsMaster(rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ func (r *RedisClusterHealer) SetRedisCustomConfig(ip string, rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ func (r *RedisClusterHealer) SetSentinelCustomConfig(ip string, rc *redisv1beta1.RedisCluster, auth *util.AuthConfig) error

+ type RedisClusterKubeClient struct

+ K8SService k8s.Services

+ func NewRedisClusterKubeClient(k8sService k8s.Services, logger logr.Logger) *RedisClusterKubeClient

+ func (r *RedisClusterKubeClient) EnsureNotPresentRedisService(rc *redisv1beta1.RedisCluster) error

+ func (r *RedisClusterKubeClient) EnsureRedisConfigMap(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureRedisService(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureRedisShutdownConfigMap(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureRedisStatefulset(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureSentinelConfigMap(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureSentinelHeadlessService(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureSentinelProbeConfigMap(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureSentinelService(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error

+ func (r *RedisClusterKubeClient) EnsureSentinelStatefulset(rc *redisv1beta1.RedisCluster, labels map[string]string, ...) error