hashkit

Documentation

Index

• Constants
• func Crc16(key []byte) (crc uint16)
• func New64a() hash.Hash64
• type HashRing
  • func Ketama() (h *HashRing)
  • func NewRing(des, method string) *HashRing
  • func (h *HashRing) AddNode(node string, spot int)
  • func (h *HashRing) DelNode(n string)
  • func (h *HashRing) GetNode(key []byte) (string, bool)
  • func (h *HashRing) Init(nodes []string, spots []int)

Constants

const (
	HashMethodFnv1a = "fnv1a_64"
)

constants defines

Functions

func Crc16

func Crc16(key []byte) (crc uint16)

Crc16 caculate key crc to divide slot of redis

func New64a

func New64a() hash.Hash64

New64a new fnv1a64 same as twemproxy.

Types

type HashRing

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

HashRing ketama hash ring.

func Ketama

func Ketama() (h *HashRing)

Ketama new a hash ring with ketama consistency. Default hash: fnv1a64

func NewRing

func NewRing(des, method string) *HashRing

NewRing will create new and need init method.

func (*HashRing) AddNode

func (h *HashRing) AddNode(node string, spot int)

AddNode a new node to the hash ring. n: name of the server s: multiplier for default number of ticks (useful when one cache node has more resources, like RAM, than another)

func (*HashRing) DelNode

func (h *HashRing) DelNode(n string)

DelNode delete a node from the hash ring. n: name of the server s: multiplier for default number of ticks (useful when one cache node has more resources, like RAM, than another)

func (*HashRing) GetNode

func (h *HashRing) GetNode(key []byte) (string, bool)

GetNode returns result node by given key.

func (*HashRing) Init

func (h *HashRing) Init(nodes []string, spots []int)

Init init hash ring with nodes.