Versions in this module Expand all Collapse all v0 v0.0.2 Mar 15, 2023 Changes in this version + func DispatchMasters(cluster *redisutil.Cluster, nodes redisutil.Nodes, nbMaster int32) (redisutil.Nodes, redisutil.Nodes, redisutil.Nodes, error) + func PlaceMasters(cluster *redisutil.Cluster, currentMaster redisutil.Nodes, ...) (redisutil.Nodes, bool, error) + func PlaceSlaves(cluster *redisutil.Cluster, masters, oldSlaves, newSlaves redisutil.Nodes, ...) (map[string]redisutil.Nodes, bool) + type Ctx struct + func NewCtx(cluster *redisutil.Cluster, nodes redisutil.Nodes, masterNum int32, ...) *Ctx + func (c *Ctx) AllocSlots(admin redisutil.IAdmin, newMasterNodes redisutil.Nodes) error + func (c *Ctx) AttachingSlavesToMaster(admin redisutil.IAdmin) error + func (c *Ctx) DispatchMasters() error + func (c *Ctx) DispatchSlotToNewMasters(admin redisutil.IAdmin, ...) error + func (c *Ctx) GetCurrentMasters() redisutil.Nodes + func (c *Ctx) GetNewMasters() redisutil.Nodes + func (c *Ctx) GetSlaves() map[string]redisutil.Nodes + func (c *Ctx) GetStatefulsetNodes() map[string]redisutil.Nodes + func (c *Ctx) PlaceMasters(ssName string) *redisutil.Node + func (c *Ctx) PlaceSlaves() error + func (c *Ctx) RebalancedCluster(admin redisutil.IAdmin, newMasterNodes redisutil.Nodes) error + type MovedNode struct + Slot redisutil.Slot + Source *redisutil.Node