types

type RedisBaseNode interface {
	v1.Object
	GetObjectKind() schema.ObjectKind
	Definition() *corev1.Pod
	Status() corev1.PodPhase
}

type RedisClusterInstance interface {
	RedisInstance
	Status() *clusterv1.DistributedRedisClusterStatus
	Definition() *clusterv1.DistributedRedisCluster
	Shards() []RedisClusterShard
	UpdateStatus(ctx context.Context, status clusterv1.ClusterStatus, message string, shards []*clusterv1.ClusterShards) error
}

type RedisClusterShard interface {
	v1.Object
	GetObjectKind() schema.ObjectKind
	Definition() *appv1.StatefulSet
	Status() *appv1.StatefulSetStatus

	// Version return the current version of redis image
	Version() redis.RedisVersion

	Index() int
	Nodes() []redis.RedisNode
	// Master returns the master node of this shard which has joined the cluster
	// Keep in mind that, this not means the master has been assigned slots
	Master() redis.RedisNode
	// Replicas returns nodes whoses role is slave
	Replicas() []redis.RedisNode

	Slots() *slot.Slots
	IsImporting() bool
	IsMigrating() bool

	Restart(ctx context.Context) error
	Refresh(ctx context.Context) error
}

type RedisFailoverInstance interface {
	RedisInstance
	Definition() *databasesv1.RedisFailover
	SentinelNodes() []redis.RedisNode
	Sentinel() RedisSentinelNodes
	UpdateStatus(ctx context.Context, status databasesv1.RedisFailoverStatus) error
	Selector() map[string]string
}

type RedisInstance interface {
	v1.Object
	Users() acl.Users
	GetObjectKind() schema.ObjectKind
	Version() redis.RedisVersion
	Masters() []redis.RedisNode
	Nodes() []redis.RedisNode
	IsInService() bool
	IsReady() bool
	Restart(ctx context.Context) error
	Refresh(ctx context.Context) error
	IsACLUserExists() bool
}

type RedisNode interface {
	RedisBaseNode
}

type RedisSentinelNode interface {
	RedisBaseNode
}

type RedisSentinelNodes interface {
	v1.Object
	GetObjectKind() schema.ObjectKind
	Definition() *appv1.Deployment
	Status() *appv1.DeploymentStatus
	// Version return the current version of redis image
	Version() redis.RedisVersion

	Nodes() []redis.RedisNode

	Restart(ctx context.Context) error
	Refresh(ctx context.Context) error
}

type RedisSentinelReplica interface {
	v1.Object
	GetObjectKind() schema.ObjectKind
	Definition() *appv1.StatefulSet
	Status() *appv1.StatefulSetStatus

	// Version return the current version of redis image
	Version() redis.RedisVersion

	Nodes() []redis.RedisNode
	// Master returns the master node of this shard which has joined the cluster
	// Keep in mind that, this not means the master has been assigned slots
	Master() redis.RedisNode
	// Replicas returns nodes whoses role is slave
	Replicas() []redis.RedisNode

	Restart(ctx context.Context) error
	Refresh(ctx context.Context) error
}