consistent

Documentation

Index

• type ConsistentHash
  • func NewConsistentHash(replicas int, hashFunc func([]byte) uint32) *ConsistentHash
  • func (c *ConsistentHash) AddNode(node *Node)
  • func (c *ConsistentHash) GetNode(hash uint32) *Node
  • func (c *ConsistentHash) RemoveNode(node *Node)
• type Node

Types

type ConsistentHash

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

func NewConsistentHash

func NewConsistentHash(replicas int, hashFunc func([]byte) uint32) *ConsistentHash

func (*ConsistentHash) AddNode

func (c *ConsistentHash) AddNode(node *Node)

func (*ConsistentHash) GetNode

func (c *ConsistentHash) GetNode(hash uint32) *Node

func (*ConsistentHash) RemoveNode

func (c *ConsistentHash) RemoveNode(node *Node)

type Node

type Node struct {
	Proxy proxy.IProxyClient
	Addr  string
	Id    int
}