zslot

Documentation

Index

• type SlotCluster
  • func NewSlotCluster(conn *zk.Conn) SlotCluster
  • func (sc *SlotCluster) Dispatch(begin uint32, end uint32, service string) error
  • func (sc *SlotCluster) Hash(Key string) (string, error)

Types

type SlotCluster

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

SlotCluster is a map to return service host

func NewSlotCluster

func NewSlotCluster(conn *zk.Conn) SlotCluster

NewSlotCluster is a help function, we will try to read from the zk, if it is not existed, we will init it and dispatch all to default service

func (*SlotCluster) Dispatch

func (sc *SlotCluster) Dispatch(begin uint32, end uint32, service string) error

Dispatch will let some slot belong to some service

func (*SlotCluster) Hash

func (sc *SlotCluster) Hash(Key string) (string, error)

Hash will hash Key and mod TotalSlotsNum, choose a slot and return