lowring

Documentation

Index

• type Node
• type Ring
  • func New(replicaCount int) *Ring
  • func (ring *Ring) AddNode(capacity int, group int) Node
  • func (ring *Ring) FillReplicaToNodeToPartitions()
  • func (ring *Ring) Rebalance(randIntn func(int) int)
  • func (ring *Ring) SetReplicaCount(v int)

Types

type Node

type Node uint16

const NilNode Node = math.MaxUint16

type Ring

type Ring struct {
	NodeToCapacity              []int
	NodeToGroup                 []int
	GroupToGroup                []int
	ReplicaToPartitionToNode    [][]Node
	MaxPartitionCount           int
	Rebalanced                  time.Time
	ReplicaToPartitionToWait    [][]uint16
	ReassignmentWait            uint16
	MaxReplicaReassignableCount int8
	ReplicaToNodeToPartitions   [][][]uint32
}

func New

func New(replicaCount int) *Ring

func (*Ring) AddNode

func (ring *Ring) AddNode(capacity int, group int) Node

func (*Ring) FillReplicaToNodeToPartitions

func (ring *Ring) FillReplicaToNodeToPartitions()

func (*Ring) Rebalance

func (ring *Ring) Rebalance(randIntn func(int) int)

func (*Ring) SetReplicaCount

func (ring *Ring) SetReplicaCount(v int)