Documentation
¶
Index ¶
- type KetamaNodeSelector
- func (nodeSel *KetamaNodeSelector) Each(f func(net.Addr) error) error
- func (nodeSel *KetamaNodeSelector) PickServer(key string) (net.Addr, error)
- func (nodeSel *KetamaNodeSelector) PickServerDych(key string) (net.Addr, error)
- func (nodeSel *KetamaNodeSelector) PickServerSeq(key string) (net.Addr, error)
- func (nodeSel *KetamaNodeSelector) SetNodes(newNodes ...string) error
- type VNode
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KetamaNodeSelector ¶
type KetamaNodeSelector struct {
// contains filtered or unexported fields
}
func NewKetamaNodeSelector ¶
func NewKetamaNodeSelector(newNodes ...string) (*KetamaNodeSelector, error)
func (*KetamaNodeSelector) Each ¶
func (nodeSel *KetamaNodeSelector) Each(f func(net.Addr) error) error
func (*KetamaNodeSelector) PickServer ¶
func (nodeSel *KetamaNodeSelector) PickServer(key string) (net.Addr, error)
func (*KetamaNodeSelector) PickServerDych ¶
func (nodeSel *KetamaNodeSelector) PickServerDych(key string) (net.Addr, error)
func (*KetamaNodeSelector) PickServerSeq ¶
func (nodeSel *KetamaNodeSelector) PickServerSeq(key string) (net.Addr, error)
func (*KetamaNodeSelector) SetNodes ¶
func (nodeSel *KetamaNodeSelector) SetNodes(newNodes ...string) error
Click to show internal directories.
Click to hide internal directories.