rpc

Documentation

Index

• func LoadRpcAddr(zkClient *zookeeper.ZkClient, dao *RpcNodeDao, srv service.ServiceType)
• func WatchRpcAddr(zkClient *zookeeper.ZkClient, dao *RpcNodeDao, srv service.ServiceType)
• type IRpcNodeDao
• type RpcNodeDao
  • func NewRpcNodeDao(dic *xdi.DiContainer) *RpcNodeDao
  • func (n *RpcNodeDao) Clear(t service.ServiceType)
  • func (n *RpcNodeDao) Delete(t service.ServiceType, path string)
  • func (n *RpcNodeDao) GetRandomOne(t service.ServiceType) *zookeeper.ZkNode
  • func (n *RpcNodeDao) Insert(t service.ServiceType, node *zookeeper.ZkNode)
  • func (n *RpcNodeDao) InsertN(t service.ServiceType, nodes []*zookeeper.ZkNode)
  • func (n *RpcNodeDao) Len(t service.ServiceType) int32
  • func (n *RpcNodeDao) Update(t service.ServiceType, node *zookeeper.ZkNode)

Functions

func LoadRpcAddr

func LoadRpcAddr(zkClient *zookeeper.ZkClient, dao *RpcNodeDao, srv service.ServiceType)

func WatchRpcAddr

func WatchRpcAddr(zkClient *zookeeper.ZkClient, dao *RpcNodeDao, srv service.ServiceType)

Types

type IRpcNodeDao

type IRpcNodeDao interface {
	Insert(t service.ServiceType, node *zookeeper.ZkNode)
	InsertN(t service.ServiceType, nodes []*zookeeper.ZkNode)
	Update(t service.ServiceType, node *zookeeper.ZkNode)
	Delete(t service.ServiceType, path string)
	GetRandomOne(t service.ServiceType) *zookeeper.ZkNode
	Len(t service.ServiceType) int32
	Clear(t service.ServiceType)
}

type RpcNodeDao

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

noinspection GoNameStartsWithPackageName

func NewRpcNodeDao

func NewRpcNodeDao(dic *xdi.DiContainer) *RpcNodeDao

func (*RpcNodeDao) Clear

func (n *RpcNodeDao) Clear(t service.ServiceType)

func (*RpcNodeDao) Delete

func (n *RpcNodeDao) Delete(t service.ServiceType, path string)

func (*RpcNodeDao) GetRandomOne

func (n *RpcNodeDao) GetRandomOne(t service.ServiceType) *zookeeper.ZkNode

func (*RpcNodeDao) Insert

func (n *RpcNodeDao) Insert(t service.ServiceType, node *zookeeper.ZkNode)

func (*RpcNodeDao) InsertN

func (n *RpcNodeDao) InsertN(t service.ServiceType, nodes []*zookeeper.ZkNode)

func (*RpcNodeDao) Len

func (n *RpcNodeDao) Len(t service.ServiceType) int32

func (*RpcNodeDao) Update

func (n *RpcNodeDao) Update(t service.ServiceType, node *zookeeper.ZkNode)