clustering

Documentation

Index

• 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
  • func NewCtx(haconf *redisv1alpha1.HAspec, cluster *redisutil.Cluster, ...) *Ctx
  • func (c *Ctx) AllocSlots(admin redisutil.IAdmin, newMasterNodes redisutil.Nodes, ctx context.Context) error
  • func (c *Ctx) AttachingSlavesToMaster(admin redisutil.IAdmin, ctx context.Context) error
  • func (c *Ctx) BuildSlotsByNode(newMasterNodes, oldMasterNodes, allMasterNodes redisutil.Nodes, nbSlots int) map[string][]redisutil.Slot
  • 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) PlaceMastersHA(stsindex int, ssName string, haconf *redisv1alpha1.HAspec) *redisutil.Node
  • func (c *Ctx) PlaceSlaves() error
  • func (c *Ctx) RebalancedCluster(admin redisutil.IAdmin, newMasterNodes redisutil.Nodes, ctx context.Context) error
• type MovedNode

Functions

func DispatchMasters

func DispatchMasters(cluster *redisutil.Cluster, nodes redisutil.Nodes, nbMaster int32) (redisutil.Nodes, redisutil.Nodes, redisutil.Nodes, error)

DispatchMasters used to select nodes with master roles

func PlaceMasters

func PlaceMasters(cluster *redisutil.Cluster, currentMaster redisutil.Nodes, allPossibleMasters redisutil.Nodes, nbMaster int32) (redisutil.Nodes, bool, error)

PlaceMasters used to select Redis Node knowing on which VM they are running in order to spread as possible the masters on different VMs. Improvement: Use Kube Node labeling instead of the "NodeName", (availability zone and so)

func PlaceSlaves

func PlaceSlaves(cluster *redisutil.Cluster, masters, oldSlaves, newSlaves redisutil.Nodes, replicationFactor int32) (map[string]redisutil.Nodes, bool)

PlaceSlaves used to select Redis Node knowing on which VM they are running in order to spread as possible

Types

type Ctx

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

func NewCtx

func NewCtx(haconf *redisv1alpha1.HAspec, cluster *redisutil.Cluster, nodes redisutil.Nodes, masterNum int32, clusterName string, log logr.Logger) *Ctx

func (*Ctx) AllocSlots

func (c *Ctx) AllocSlots(admin redisutil.IAdmin, newMasterNodes redisutil.Nodes, ctx context.Context) error

func (*Ctx) AttachingSlavesToMaster

func (c *Ctx) AttachingSlavesToMaster(admin redisutil.IAdmin, ctx context.Context) error

AttachingSlavesToMaster used to attach slaves to there masters

func (*Ctx) BuildSlotsByNode

func (c *Ctx) BuildSlotsByNode(newMasterNodes, oldMasterNodes, allMasterNodes redisutil.Nodes, nbSlots int) map[string][]redisutil.Slot

buildSlotsByNode get all slots that have to be migrated with retrieveSlotToMigrateFrom and retrieveSlotToMigrateFromRemovedNodes and assign those slots to node that need them

func (*Ctx) DispatchMasters

func (c *Ctx) DispatchMasters() error

func (*Ctx) DispatchSlotToNewMasters

func (c *Ctx) DispatchSlotToNewMasters(admin redisutil.IAdmin, newMasterNodes, currentMasterNodes, allMasterNodes redisutil.Nodes, ctx context.Context) error

DispatchSlotToNewMasters used to dispatch Slot to the new master nodes

func (*Ctx) GetCurrentMasters

func (c *Ctx) GetCurrentMasters() redisutil.Nodes

func (*Ctx) GetNewMasters

func (c *Ctx) GetNewMasters() redisutil.Nodes

func (*Ctx) GetSlaves

func (c *Ctx) GetSlaves() map[string]redisutil.Nodes

func (*Ctx) GetStatefulsetNodes

func (c *Ctx) GetStatefulsetNodes() map[string]redisutil.Nodes

func (*Ctx) PlaceMasters

func (c *Ctx) PlaceMasters(ssName string) *redisutil.Node

func (*Ctx) PlaceMastersHA

func (c *Ctx) PlaceMastersHA(stsindex int, ssName string, haconf *redisv1alpha1.HAspec) *redisutil.Node

func (*Ctx) PlaceSlaves

func (c *Ctx) PlaceSlaves() error

func (*Ctx) RebalancedCluster

func (c *Ctx) RebalancedCluster(admin redisutil.IAdmin, newMasterNodes redisutil.Nodes, ctx context.Context) error

RebalancedCluster rebalanced a redis cluster.

type MovedNode

type MovedNode struct {
	Source *redisutil.Node
	Slot   redisutil.Slot
}