ketama

Documentation

Index

• type Ketama
  • func New() *Ketama
  • func (k *Ketama) Get(path string) (*types.UpstreamAddress, error)
  • func (k *Ketama) Set(upstreams []*types.UpstreamAddress)

Types

type Ketama

type Ketama struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Ketama implements upstream balancing that is based on the Ketama consistent hashing algorithm.

func New

func New() *Ketama

New creates a new ketama consistent hash upstream balancer.

func (*Ketama) Get

func (k *Ketama) Get(path string) (*types.UpstreamAddress, error)

Get implements the balancing algorithm interface.

func (*Ketama) Set

func (k *Ketama) Set(upstreams []*types.UpstreamAddress)

Set implements the balancing algorithm interface.