README
¶
gomcketama 
This package implements a ServerSelector for gomemcache that provides ketama hashing that's compatible with SpyMemcached's ketama hashing.
Usage
import "github.com/thatguystone/gomcketama"
// Create a memcache client using ketama as the server selector
mc := gomcketama.New("server1:11211", "server2:11211")
Documentation
¶
Overview ¶
Package gomcketama implements a ServerSelector for gomemcache that provides ketama hashing that's compatible with SpyMemcached's ketama hashing.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type KetamaServerSelector ¶
type KetamaServerSelector struct {
// contains filtered or unexported fields
}
KetamaServerSelector implements gomemcache's ServerSelector
func (*KetamaServerSelector) AddServer ¶
func (ks *KetamaServerSelector) AddServer(server string) error
AddServer adds a server to the ketama continuum.
func (*KetamaServerSelector) Each ¶
func (ks *KetamaServerSelector) Each(f func(net.Addr) error) error
Each loops through all registered servers, calling the given function.
func (*KetamaServerSelector) PickServer ¶
func (ks *KetamaServerSelector) PickServer(key string) (net.Addr, error)
PickServer returns the server address that a given item should be written to.
Source Files
Click to show internal directories.
Click to hide internal directories.