hashkit

Documentation

Index

• Constants
• func Fnv1a64(key []byte) uint32
• func Xxh3(key []byte) uint32
• type Continuum
  • func NewKetama(servers []*Server, hashFn func(key []byte) uint32) *Continuum
  • func (c *Continuum) Dispatch(key string) uint32
  • func (c *Continuum) Rebuild(servers []*Server)
• type HashKit
• type Server

Constants

const KetamaPointsPerServer = 160

Functions

func Fnv1a64

func Fnv1a64(key []byte) uint32

func Xxh3

func Xxh3(key []byte) uint32

Xxh3 https://github.com/rurban/smhasher/blob/master/doc/xxh3low.txt https://github.com/kelindar/hashbench

Types

type Continuum

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

func NewKetama

func NewKetama(servers []*Server, hashFn func(key []byte) uint32) *Continuum

func (*Continuum) Dispatch

func (c *Continuum) Dispatch(key string) uint32

func (*Continuum) Rebuild

func (c *Continuum) Rebuild(servers []*Server)

type HashKit

type HashKit interface {
	Dispatch(key string) uint32
	Rebuild(servers []*Server)
}

type Server

type Server struct {
	Name   string
	Weight int64
	Index  uint32
}