redis

May 27, 2022

Changes in this version

type ClusterNodes

+ func (c *ClusterNodes) ForgetNode(ctx context.Context, forgetNode *Node) error

+ func (c *ClusterNodes) GetCommandingNode(ctx context.Context) (*Node, error)

+ func (c *ClusterNodes) GetFailingNodes(ctx context.Context) ([]*Node, error)

May 25, 2022

Changes in this version

type ClusterNodes

+ func (c *ClusterNodes) EnsureClusterReplicationRatio(ctx context.Context, cluster *v1alpha1.RedisCluster) error

+ func (c *ClusterNodes) GetMasters() []*Node

+ func (c *ClusterNodes) GetReplicas() []*Node

+ func (c *ClusterNodes) ReloadNodes(ctx context.Context) error

type Node

+ func (n *Node) ReloadNodeInfo(ctx context.Context) error

May 19, 2022

Changes in this version

+ const TotalRedisSlots

+ func ProcessSlotStrings(slotStrings []string) []int32

+ type ClusterNodes struct

+ Nodes []*Node

+ func (c *ClusterNodes) CalculateSlotAssignment() map[*Node][]int32

+ func (c *ClusterNodes) ClusterMeet(ctx context.Context) error

+ func (c *ClusterNodes) GetAssignedSlots() []int32

+ func (c *ClusterNodes) GetMissingSlots() []int32

+ type Node struct

+ NodeAttributes NodeAttributes

+ func NewNode(ctx context.Context, opt *redis.Options, ...) (*Node, error)

+ func (n *Node) GetFriends(ctx context.Context) ([]*Node, error)

+ func (n *Node) GetSelfAttributes(ctx context.Context) (NodeAttributes, error)

+ func (n *Node) IsMaster() bool

+ func (n *Node) MeetNode(ctx context.Context, node *Node) error

+ type NodeAttributes struct

+ ID string

+ func NewNodeAttributes(nodeString string) NodeAttributes

+ func (n *NodeAttributes) HasFlag(flag string) bool