redis

Documentation

Index

• type RedisNode
  • func NewRedisNode(info string) *RedisNode
  • func (n *RedisNode) IsMaster() bool
  • func (n *RedisNode) SlotsCount() int
  • func (n *RedisNode) String() string
• type RedisPod
  • func NewRedisPod(podname string, redisContainerName string, namespace string, port int, ...) (*RedisPod, error)
  • func NewRedisPodWithPod(pod *corev1.Pod, redisContainerName string, port int, ...) *RedisPod
  • func (r *RedisPod) Call(cmd ...string) (string, error)
  • func (r *RedisPod) ClusterAddNode(newPod *RedisPod, slave bool) (result string, err error)
  • func (r *RedisPod) ClusterCheck() error
  • func (r *RedisPod) ClusterCreate(replicas int, yes bool, pods ...*RedisPod) (string, error)
  • func (r *RedisPod) ClusterDelNode(nodeID string) (result string, err error)
  • func (r *RedisPod) ClusterFailover(force, takeover bool) (string, error)
  • func (r *RedisPod) ClusterInfo() (string, error)
  • func (r *RedisPod) ClusterNodes() (nodes []*RedisNode, err error)
  • func (r *RedisPod) ClusterRebalance(weights map[string]string, useEmptyMasters bool, timeout int, simulate bool, ...) (string, error)
  • func (r *RedisPod) ClusterSlots() ([]*Slots, error)
  • func (r *RedisPod) ConfigGet(key string) (string, error)
  • func (r *RedisPod) ConfigSet(key, value string) (string, error)
  • func (r *RedisPod) GetIP() string
  • func (r *RedisPod) GetName() string
  • func (r *RedisPod) GetNodeID() (nodeID string, err error)
  • func (r *RedisPod) Ping() (string, error)
• type Slots

Types

type RedisNode

type RedisNode struct {
	ID        string
	Pod       *corev1.Pod
	IP        string
	Flags     []string
	MasterID  string
	Epoch     int
	LinkState string
	Slots     []string
}

func NewRedisNode

func NewRedisNode(info string) *RedisNode

https://redis.io/commands/cluster-nodes

func (*RedisNode) IsMaster

func (n *RedisNode) IsMaster() bool

func (*RedisNode) SlotsCount

func (n *RedisNode) SlotsCount() int

func (*RedisNode) String

func (n *RedisNode) String() string

type RedisPod

type RedisPod struct {
	// contains filtered or unexported fields
}

func NewRedisPod

func NewRedisPod(podname string, redisContainerName string, namespace string, port int, clientset *kubernetes.Clientset, restcfg *restclient.Config) (*RedisPod, error)

func NewRedisPodWithPod

func NewRedisPodWithPod(pod *corev1.Pod, redisContainerName string, port int, clientset *kubernetes.Clientset, restcfg *restclient.Config) *RedisPod

func (*RedisPod) Call

func (r *RedisPod) Call(cmd ...string) (string, error)

func (*RedisPod) ClusterAddNode

func (r *RedisPod) ClusterAddNode(newPod *RedisPod, slave bool) (result string, err error)

func (*RedisPod) ClusterCheck

func (r *RedisPod) ClusterCheck() error

func (*RedisPod) ClusterCreate

func (r *RedisPod) ClusterCreate(replicas int, yes bool, pods ...*RedisPod) (string, error)

func (*RedisPod) ClusterDelNode

func (r *RedisPod) ClusterDelNode(nodeID string) (result string, err error)

func (*RedisPod) ClusterFailover

func (r *RedisPod) ClusterFailover(force, takeover bool) (string, error)

func (*RedisPod) ClusterInfo

func (r *RedisPod) ClusterInfo() (string, error)

func (*RedisPod) ClusterNodes

func (r *RedisPod) ClusterNodes() (nodes []*RedisNode, err error)

ClusterNodes return redis nodes with pod info

func (*RedisPod) ClusterRebalance

func (r *RedisPod) ClusterRebalance(weights map[string]string, useEmptyMasters bool, timeout int, simulate bool, batch int, threshold int, replace bool) (string, error)

func (*RedisPod) ClusterSlots

func (r *RedisPod) ClusterSlots() ([]*Slots, error)

func (*RedisPod) ConfigGet

func (r *RedisPod) ConfigGet(key string) (string, error)

func (*RedisPod) ConfigSet

func (r *RedisPod) ConfigSet(key, value string) (string, error)

func (*RedisPod) GetIP

func (r *RedisPod) GetIP() string

func (*RedisPod) GetName

func (r *RedisPod) GetName() string

func (*RedisPod) GetNodeID

func (r *RedisPod) GetNodeID() (nodeID string, err error)

func (*RedisPod) Ping

func (r *RedisPod) Ping() (string, error)

type Slots

type Slots struct {
	Start  int
	End    int
	Master *RedisPod
	Slaves []*RedisPod
}