sentinel

Documentation

Index

• func LoadRedisSentinelNodes(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, ...) (types.RedisSentinelNodes, error)
• func LoadRedisSentinelReplicas(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, ...) ([]types.RedisSentinelReplica, error)
• func NewRedisSentinelNode(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, ...) (types.RedisSentinelNodes, error)
• func NewRedisSentinelReplica(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, ...) (types.RedisSentinelReplica, error)
• type RedisFailover
  • func NewRedisFailover(ctx context.Context, k8sClient clientset.ClientSet, ...) (*RedisFailover, error)
  • func (c *RedisFailover) Definition() *databasesv1.RedisFailover
  • func (c *RedisFailover) IsACLUserExists() bool
  • func (c *RedisFailover) IsInService() bool
  • func (c *RedisFailover) IsReady() bool
  • func (c *RedisFailover) LoadRedisUsers(ctx context.Context)
  • func (c *RedisFailover) Masters() []redis.RedisNode
  • func (c *RedisFailover) Nodes() []redis.RedisNode
  • func (c *RedisFailover) Refresh(ctx context.Context) error
  • func (c *RedisFailover) Restart(ctx context.Context) error
  • func (c *RedisFailover) Selector() map[string]string
  • func (c *RedisFailover) Sentinel() types.RedisSentinelNodes
  • func (c *RedisFailover) SentinelNodes() []redis.RedisNode
  • func (c *RedisFailover) UpdateStatus(ctx context.Context, status databasesv1.RedisFailoverStatus) error
  • func (c *RedisFailover) Users() (us acl.Users)
  • func (c *RedisFailover) Version() redis.RedisVersion
• type RedisSentinelNodes
  • func (s *RedisSentinelNodes) Definition() *appv1.Deployment
  • func (s *RedisSentinelNodes) Nodes() []redis.RedisNode
  • func (s *RedisSentinelNodes) Refresh(ctx context.Context) error
  • func (s *RedisSentinelNodes) Restart(ctx context.Context) error
  • func (s *RedisSentinelNodes) Status() *appv1.DeploymentStatus
  • func (s *RedisSentinelNodes) Version() redis.RedisVersion
• type RedisSentinelReplica
  • func (s *RedisSentinelReplica) Definition() *appv1.StatefulSet
  • func (s *RedisSentinelReplica) Master() redis.RedisNode
  • func (s *RedisSentinelReplica) Nodes() []redis.RedisNode
  • func (s *RedisSentinelReplica) Refresh(ctx context.Context) error
  • func (s *RedisSentinelReplica) Replicas() []redis.RedisNode
  • func (s *RedisSentinelReplica) Restart(ctx context.Context) error
  • func (s *RedisSentinelReplica) Status() *appv1.StatefulSetStatus
  • func (s *RedisSentinelReplica) Version() redis.RedisVersion

Functions

func LoadRedisSentinelNodes

func LoadRedisSentinelNodes(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, logger logr.Logger) (types.RedisSentinelNodes, error)

func LoadRedisSentinelReplicas

func LoadRedisSentinelReplicas(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, logger logr.Logger) ([]types.RedisSentinelReplica, error)

func NewRedisSentinelNode

func NewRedisSentinelNode(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, deploy *appv1.Deployment, logger logr.Logger) (types.RedisSentinelNodes, error)

func NewRedisSentinelReplica

func NewRedisSentinelReplica(ctx context.Context, client clientset.ClientSet, sentinel types.RedisInstance, sts *appv1.StatefulSet, logger logr.Logger) (types.RedisSentinelReplica, error)

Types

type RedisFailover

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

func NewRedisFailover

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

func (*RedisFailover) Definition

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

func (*RedisFailover) IsACLUserExists

func (c *RedisFailover) IsACLUserExists() bool

func (*RedisFailover) IsInService

func (c *RedisFailover) IsInService() bool

func (*RedisFailover) IsReady

func (c *RedisFailover) IsReady() bool

func (*RedisFailover) LoadRedisUsers

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

func (*RedisFailover) Masters

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

func (*RedisFailover) Nodes

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

func (*RedisFailover) Refresh

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

func (*RedisFailover) Restart

func (c *RedisFailover) Restart(ctx context.Context) error

func (*RedisFailover) Selector

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

func (*RedisFailover) Sentinel

func (c *RedisFailover) Sentinel() types.RedisSentinelNodes

func (*RedisFailover) SentinelNodes

func (c *RedisFailover) SentinelNodes() []redis.RedisNode

func (*RedisFailover) UpdateStatus

func (c *RedisFailover) UpdateStatus(ctx context.Context, status databasesv1.RedisFailoverStatus) error

func (*RedisFailover) Users

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

func (*RedisFailover) Version

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

type RedisSentinelNodes

type RedisSentinelNodes struct {
	appv1.Deployment
	// contains filtered or unexported fields
}

func (*RedisSentinelNodes) Definition

func (s *RedisSentinelNodes) Definition() *appv1.Deployment

func (*RedisSentinelNodes) Nodes

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

func (*RedisSentinelNodes) Refresh

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

func (*RedisSentinelNodes) Restart

func (s *RedisSentinelNodes) Restart(ctx context.Context) error

func (*RedisSentinelNodes) Status

func (s *RedisSentinelNodes) Status() *appv1.DeploymentStatus

func (*RedisSentinelNodes) Version

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

type RedisSentinelReplica

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

func (*RedisSentinelReplica) Definition

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

func (*RedisSentinelReplica) Master

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

func (*RedisSentinelReplica) Nodes

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

func (*RedisSentinelReplica) Refresh

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

func (*RedisSentinelReplica) Replicas

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

func (*RedisSentinelReplica) Restart

func (s *RedisSentinelReplica) Restart(ctx context.Context) error

func (*RedisSentinelReplica) Status

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

func (*RedisSentinelReplica) Version

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