router

Documentation

Index

• type FeatureShard
  • func NewFeatureShard(nodes []string, replicaNum int) *FeatureShard
  • func (this *FeatureShard) GetNodesByFeature(key []int64) (nodes []string, err error)
  • func (this *FeatureShard) SetNodes(nodes []string, replicaNum int) *FeatureShard
• type Rpc
  • func NewRpc() *Rpc
  • func (this *Rpc) GetNodesByFeature(key []int64) (r []string, ex *rpc.RouterException, err error)
  • func (this *Rpc) SetNodes(nodes []string) (ex *rpc.RouterException, err error)
  • func (this *Rpc) Start(host string, port int) (err error)
  • func (this *Rpc) Stop() (err error)
  • func (this *Rpc) Wait()

Types

type FeatureShard

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

func NewFeatureShard

func NewFeatureShard(nodes []string, replicaNum int) *FeatureShard

func (*FeatureShard) GetNodesByFeature

func (this *FeatureShard) GetNodesByFeature(key []int64) (nodes []string, err error)

func (*FeatureShard) SetNodes

func (this *FeatureShard) SetNodes(nodes []string, replicaNum int) *FeatureShard

type Rpc

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

func NewRpc

func NewRpc() *Rpc

func (*Rpc) GetNodesByFeature

func (this *Rpc) GetNodesByFeature(key []int64) (r []string, ex *rpc.RouterException, err error)

func (*Rpc) SetNodes

func (this *Rpc) SetNodes(nodes []string) (ex *rpc.RouterException, err error)

func (*Rpc) Start

func (this *Rpc) Start(host string, port int) (err error)

func (*Rpc) Stop

func (this *Rpc) Stop() (err error)

func (*Rpc) Wait

func (this *Rpc) Wait()