shard

Documentation

Index

• Constants
• func CRC16Sum(key string) uint16
• type Node
• type SlotsManager
  • func InitSlotManager(startNodes []Node) *SlotsManager
  • func RestoreSlotsManager(nds []Node) (*SlotsManager, error)
  • func (sm *SlotsManager) Check()
  • func (sm *SlotsManager) NodeByKey(key string) (*Node, error)
  • func (sm *SlotsManager) NodeBySlot(n uint16) (*Node, error)
  • func (sm *SlotsManager) Nodes() []Node
• type SlotsRange

Constants

const (
	SLOTS_NUM = 1 << 14
)

Functions

func CRC16Sum

func CRC16Sum(key string) uint16

Types

type Node

type Node struct {
	ID    string     `json:"id"`
	Slots SlotsRange `json:"slots"`
}

type SlotsManager

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

func InitSlotManager

func InitSlotManager(startNodes []Node) *SlotsManager

func RestoreSlotsManager

func RestoreSlotsManager(nds []Node) (*SlotsManager, error)

func (*SlotsManager) Check

func (sm *SlotsManager) Check()

func (*SlotsManager) NodeByKey

func (sm *SlotsManager) NodeByKey(key string) (*Node, error)

func (*SlotsManager) NodeBySlot

func (sm *SlotsManager) NodeBySlot(n uint16) (*Node, error)

func (*SlotsManager) Nodes

func (sm *SlotsManager) Nodes() []Node

type SlotsRange

type SlotsRange struct {
	Start uint16 `json:"start"`
	End   uint16 `json:"end"`
}