failover

Documentation

Index

• func LoadRedisReplication(ctx context.Context, client clientset.ClientSet, ...) (types.RedisReplication, error)
• func NewRedisReplication(ctx context.Context, client clientset.ClientSet, ...) (types.RedisReplication, error)
• type RedisFailover
  • func NewRedisFailover(ctx context.Context, k8sClient clientset.ClientSet, ...) (*RedisFailover, error)
  • func (s *RedisFailover) Arch() redis.RedisArch
  • func (s *RedisFailover) Definition() *databasesv1.RedisFailover
  • func (s *RedisFailover) IsACLAppliedToAll() bool
  • func (s *RedisFailover) IsACLUserExists() bool
  • func (s *RedisFailover) IsBindedSentinel() bool
  • func (s *RedisFailover) IsInService() bool
  • func (s *RedisFailover) IsReady() bool
  • func (s *RedisFailover) IsResourceFullfilled(ctx context.Context) (bool, error)
  • func (c *RedisFailover) IsStandalone() bool
  • func (s *RedisFailover) LoadRedisUsers(ctx context.Context)
  • func (c *RedisFailover) Logger() logr.Logger
  • func (s *RedisFailover) Masters() []redis.RedisNode
  • func (s *RedisFailover) Monitor() types.FailoverMonitor
  • func (s *RedisFailover) NamespacedName() client.ObjectKey
  • func (s *RedisFailover) Nodes() []redis.RedisNode
  • func (s *RedisFailover) RawNodes(ctx context.Context) ([]corev1.Pod, error)
  • func (s *RedisFailover) Refresh(ctx context.Context) error
  • func (s *RedisFailover) Restart(ctx context.Context, annotationKeyVal ...string) error
  • func (s *RedisFailover) Selector() map[string]string
  • func (c *RedisFailover) SendEventf(eventtype, reason, messageFmt string, args ...interface{})
  • func (s *RedisFailover) TLSConfig() *tls.Config
  • func (s *RedisFailover) UpdateStatus(ctx context.Context, st types.InstanceStatus, msg string) error
  • func (s *RedisFailover) Users() (us acl.Users)
  • func (s *RedisFailover) Version() redis.RedisVersion
• type RedisReplication
  • func (s *RedisReplication) Definition() *appv1.StatefulSet
  • func (s *RedisReplication) IsReady() bool
  • func (s *RedisReplication) Master() redis.RedisNode
  • func (s *RedisReplication) NamespacedName() client.ObjectKey
  • func (s *RedisReplication) Nodes() []redis.RedisNode
  • func (s *RedisReplication) Refresh(ctx context.Context) error
  • func (s *RedisReplication) Replicas() []redis.RedisNode
  • func (s *RedisReplication) Restart(ctx context.Context, annotationKeyVal ...string) error
  • func (s *RedisReplication) Status() *appv1.StatefulSetStatus
  • func (s *RedisReplication) Version() redis.RedisVersion

Functions

func LoadRedisReplication

func LoadRedisReplication(ctx context.Context, client clientset.ClientSet, inst types.RedisFailoverInstance, logger logr.Logger) (types.RedisReplication, error)

func NewRedisReplication

func NewRedisReplication(ctx context.Context, client clientset.ClientSet, inst types.RedisFailoverInstance, sts *appv1.StatefulSet, logger logr.Logger) (types.RedisReplication, error)

Types

type RedisFailover

type RedisFailover struct {
	databasesv1.RedisFailover
	// contains filtered or unexported fields
}

func NewRedisFailover

func NewRedisFailover(ctx context.Context, k8sClient clientset.ClientSet, eventRecorder record.EventRecorder, def *databasesv1.RedisFailover, logger logr.Logger) (*RedisFailover, error)

func (*RedisFailover) Arch

func (s *RedisFailover) Arch() redis.RedisArch

func (*RedisFailover) Definition

func (s *RedisFailover) Definition() *databasesv1.RedisFailover

func (*RedisFailover) IsACLAppliedToAll

func (s *RedisFailover) IsACLAppliedToAll() bool

func (*RedisFailover) IsACLUserExists

func (s *RedisFailover) IsACLUserExists() bool

func (*RedisFailover) IsBindedSentinel

func (s *RedisFailover) IsBindedSentinel() bool

func (*RedisFailover) IsInService

func (s *RedisFailover) IsInService() bool

func (*RedisFailover) IsReady

func (s *RedisFailover) IsReady() bool

func (*RedisFailover) IsResourceFullfilled

func (s *RedisFailover) IsResourceFullfilled(ctx context.Context) (bool, error)

func (*RedisFailover) IsStandalone

func (c *RedisFailover) IsStandalone() bool

func (*RedisFailover) LoadRedisUsers

func (s *RedisFailover) LoadRedisUsers(ctx context.Context)

func (*RedisFailover) Logger

func (c *RedisFailover) Logger() logr.Logger

func (*RedisFailover) Masters

func (s *RedisFailover) Masters() []redis.RedisNode

func (*RedisFailover) Monitor

func (s *RedisFailover) Monitor() types.FailoverMonitor

func (*RedisFailover) NamespacedName

func (s *RedisFailover) NamespacedName() client.ObjectKey

func (*RedisFailover) Nodes

func (s *RedisFailover) Nodes() []redis.RedisNode

func (*RedisFailover) RawNodes

func (s *RedisFailover) RawNodes(ctx context.Context) ([]corev1.Pod, error)

func (*RedisFailover) Refresh

func (s *RedisFailover) Refresh(ctx context.Context) error

func (*RedisFailover) Restart

func (s *RedisFailover) Restart(ctx context.Context, annotationKeyVal ...string) error

func (*RedisFailover) Selector

func (s *RedisFailover) Selector() map[string]string

func (*RedisFailover) SendEventf

func (c *RedisFailover) SendEventf(eventtype, reason, messageFmt string, args ...interface{})

func (*RedisFailover) TLSConfig

func (s *RedisFailover) TLSConfig() *tls.Config

func (*RedisFailover) UpdateStatus

func (s *RedisFailover) UpdateStatus(ctx context.Context, st types.InstanceStatus, msg string) error

func (*RedisFailover) Users

func (s *RedisFailover) Users() (us acl.Users)

func (*RedisFailover) Version

func (s *RedisFailover) Version() redis.RedisVersion

type RedisReplication

type RedisReplication struct {
	appv1.StatefulSet
	// contains filtered or unexported fields
}

func (*RedisReplication) Definition

func (s *RedisReplication) Definition() *appv1.StatefulSet

func (*RedisReplication) IsReady

func (s *RedisReplication) IsReady() bool

func (*RedisReplication) Master

func (s *RedisReplication) Master() redis.RedisNode

func (*RedisReplication) NamespacedName

func (s *RedisReplication) NamespacedName() client.ObjectKey

func (*RedisReplication) Nodes

func (s *RedisReplication) Nodes() []redis.RedisNode

func (*RedisReplication) Refresh

func (s *RedisReplication) Refresh(ctx context.Context) error

func (*RedisReplication) Replicas

func (s *RedisReplication) Replicas() []redis.RedisNode

func (*RedisReplication) Restart

func (s *RedisReplication) Restart(ctx context.Context, annotationKeyVal ...string) error

func (*RedisReplication) Status

func (s *RedisReplication) Status() *appv1.StatefulSetStatus

func (*RedisReplication) Version

func (s *RedisReplication) Version() redis.RedisVersion