cluster

Documentation

Index

• func LoadRedisClusterShards(ctx context.Context, client clientset.ClientSet, ...) ([]types.RedisClusterShard, error)
• func NewRedisClusterShard(ctx context.Context, client clientset.ClientSet, ...) (types.RedisClusterShard, error)
• type RedisCluster
  • func NewRedisCluster(ctx context.Context, k8sClient clientset.ClientSet, ...) (*RedisCluster, error)
  • func (c *RedisCluster) Definition() *clusterv1.DistributedRedisCluster
  • func (c *RedisCluster) IsACLUserExists() bool
  • func (c *RedisCluster) IsInService() bool
  • func (c *RedisCluster) IsReady() bool
  • func (c *RedisCluster) LoadRedisUsers(ctx context.Context)
  • func (c *RedisCluster) Masters() []redis.RedisNode
  • func (c *RedisCluster) Nodes() []redis.RedisNode
  • func (c *RedisCluster) Refresh(ctx context.Context) error
  • func (c *RedisCluster) Restart(ctx context.Context) error
  • func (c *RedisCluster) Shards() []types.RedisClusterShard
  • func (c *RedisCluster) Status() *clusterv1.DistributedRedisClusterStatus
  • func (c *RedisCluster) TLS() *tls.Config
  • func (c *RedisCluster) UntrustedNodes() []redis.RedisNode
  • func (c *RedisCluster) UpdateStatus(ctx context.Context, status clusterv1.ClusterStatus, message string, ...) error
  • func (c *RedisCluster) Users() (us acl.Users)
  • func (c *RedisCluster) Version() redis.RedisVersion
• type RedisClusterShard
  • func (s *RedisClusterShard) Definition() *appv1.StatefulSet
  • func (s *RedisClusterShard) Index() int
  • func (s *RedisClusterShard) IsImporting() bool
  • func (s *RedisClusterShard) IsMigrating() bool
  • func (s *RedisClusterShard) Master() redis.RedisNode
  • func (s *RedisClusterShard) Nodes() []redis.RedisNode
  • func (s *RedisClusterShard) Refresh(ctx context.Context) error
  • func (s *RedisClusterShard) Replicas() []redis.RedisNode
  • func (s *RedisClusterShard) Restart(ctx context.Context) error
  • func (s *RedisClusterShard) Slots() *slot.Slots
  • func (s *RedisClusterShard) Status() *appv1.StatefulSetStatus
  • func (s *RedisClusterShard) Version() redis.RedisVersion

Functions

func LoadRedisClusterShards

func LoadRedisClusterShards(ctx context.Context, client clientset.ClientSet, cluster types.RedisClusterInstance, logger logr.Logger) ([]types.RedisClusterShard, error)

func NewRedisClusterShard

func NewRedisClusterShard(ctx context.Context, client clientset.ClientSet, cluster types.RedisClusterInstance, sts *appv1.StatefulSet, logger logr.Logger) (types.RedisClusterShard, error)

NewRedisClusterShard

Types

type RedisCluster

type RedisCluster struct {
	clusterv1.DistributedRedisCluster
	// contains filtered or unexported fields
}

func NewRedisCluster

func NewRedisCluster(ctx context.Context, k8sClient clientset.ClientSet, def *clusterv1.DistributedRedisCluster, logger logr.Logger) (*RedisCluster, error)

NewRedisCluster

func (*RedisCluster) Definition

func (c *RedisCluster) Definition() *clusterv1.DistributedRedisCluster

Definition

func (*RedisCluster) IsACLUserExists

func (c *RedisCluster) IsACLUserExists() bool

func (*RedisCluster) IsInService

func (c *RedisCluster) IsInService() bool

IsInService

func (*RedisCluster) IsReady

func (c *RedisCluster) IsReady() bool

IsReady

func (*RedisCluster) LoadRedisUsers

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

func (*RedisCluster) Masters

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

func (*RedisCluster) Nodes

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

func (*RedisCluster) Refresh

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

Refresh refresh users, shards

func (*RedisCluster) Restart

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

ctx

func (*RedisCluster) Shards

func (c *RedisCluster) Shards() []types.RedisClusterShard

func (*RedisCluster) Status

func (c *RedisCluster) Status() *clusterv1.DistributedRedisClusterStatus

UpdateStatus

func (*RedisCluster) TLS

func (c *RedisCluster) TLS() *tls.Config

TLS

func (*RedisCluster) UntrustedNodes

func (c *RedisCluster) UntrustedNodes() []redis.RedisNode

func (*RedisCluster) UpdateStatus

func (c *RedisCluster) UpdateStatus(ctx context.Context, status clusterv1.ClusterStatus, message string, shards []*clusterv1.ClusterShards) error

UpdateStatus

func (*RedisCluster) Users

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

func (*RedisCluster) Version

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

Version

type RedisClusterShard

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

RedisClusterShard

func (*RedisClusterShard) Definition

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

func (*RedisClusterShard) Index

func (s *RedisClusterShard) Index() int

Index redis shard index. so the statefulset name must match ^drc-<name>-[0-9]+$ format

func (*RedisClusterShard) IsImporting

func (s *RedisClusterShard) IsImporting() bool

IsImporting

func (*RedisClusterShard) IsMigrating

func (s *RedisClusterShard) IsMigrating() bool

IsMigrating

func (*RedisClusterShard) Master

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

Master for nodes not join the cluster, it's role is also master

func (*RedisClusterShard) Nodes

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

Nodes returns all the nodes of this slots

func (*RedisClusterShard) Refresh

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

Refresh

func (*RedisClusterShard) Replicas

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

func (*RedisClusterShard) Restart

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

Restart

func (*RedisClusterShard) Slots

func (s *RedisClusterShard) Slots() *slot.Slots

Slots

func (*RedisClusterShard) Status

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

func (*RedisClusterShard) Version

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

Version