consistent

Jan 28, 2025

Changes in this version

+ const DefaultLoad

+ const DefaultPartitionCount

+ const DefaultPickerWidth

+ const DefaultReplicationFactor

+ type Config struct

+ Hasher Hasher

+ Load float64

+ PartitionCount int

+ PickerWidth int

+ ReplicationFactor int

type Consistent

+ func New(config Config) *Consistent

+ func (c *Consistent) ClosestN(key []byte, count int) ([]Member, error)

+ func (c *Consistent) GetAverageLoad() float64

+ func (c *Consistent) GetLoadDistribution() map[string]float64

+ func (c *Consistent) GetPartitionID(key []byte) int

+ func (c *Consistent) GetPartitionOwner(partitionID int) Member

+ func (c *Consistent) LocateKey(key []byte) Member

+ func (c *Consistent) Members() []Member

+ type Hasher func([]byte) uint64

+ type Member interface

+ String func() string

Jul 4, 2023

Changes in this version

type ConsistentHash

+ Nodes map[string]*grpc.ClientConn

May 4, 2023

Changes in this version

+ const TopWeight

+ func Hash(data []byte) uint64

+ func Md5(data []byte) []byte

+ func Md5Hex(data []byte) string

+ type Consistent interface

+ Add func(node string)

+ AddKey func(key string) bool

+ AddWithReplicas func(node string, replicas int)

+ AddWithWeight func(node string, weight int)

+ Get func(v string) (string, bool)

+ Remove func(node string)

+ SyncNodes func(g *gossip.Gossip)

+ type ConsistentHash struct

+ func NewConsistentHash(replicas int, nodes []string, fn Func) *ConsistentHash

+ func (h *ConsistentHash) Add(node string)

+ func (h *ConsistentHash) AddKey(key string) bool

+ func (h *ConsistentHash) AddWithReplicas(node string, replicas int)

+ func (h *ConsistentHash) AddWithWeight(node string, weight int)

+ func (h *ConsistentHash) Get(v string) (string, bool)

+ func (h *ConsistentHash) Remove(node string)

+ func (h *ConsistentHash) SyncNodes(g *gossip.Gossip)

+ type Func func(data []byte) uint64