ketama

Documentation

Index

• Variables
• func ServerAddr(addr string) (net.Addr, error)
• type Continuum
  • func New(serverList []ServerInfo, newHash func() hash.Hash) *Continuum
  • func NewFromFile(filename string) (*Continuum, error)
  • func (cont *Continuum) Each(f func(net.Addr) error) error
  • func (cont *Continuum) GetHash(in string, offset int) uint32
  • func (cont *Continuum) PickServer(key string) (net.Addr, error)
• type ServerInfo

Variables

var (
	ErrNoServers       = errors.New("No valid server definitions found")
	ErrMalformedServer = errors.New("One of the servers is in an invalid format")
)

Functions

func ServerAddr

func ServerAddr(addr string) (net.Addr, error)

Types

type Continuum

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

func New

func New(serverList []ServerInfo, newHash func() hash.Hash) *Continuum

Construct a new Continum for the given servers and hashing function

func NewFromFile

func NewFromFile(filename string) (*Continuum, error)

func (*Continuum) Each

func (cont *Continuum) Each(f func(net.Addr) error) error

Each iterates over each server calling the given function

func (*Continuum) GetHash

func (cont *Continuum) GetHash(in string, offset int) uint32

func (*Continuum) PickServer

func (cont *Continuum) PickServer(key string) (net.Addr, error)

type ServerInfo

type ServerInfo struct {
	Addr   net.Addr
	Memory uint64
}

A non-zero value for Memory enables ketama weighted