server

func (*MsgpackCodec) Decode ¶

func (c *MsgpackCodec) Decode(data []byte, i interface{}) error

func (*MsgpackCodec) Encode ¶

func (c *MsgpackCodec) Encode(i interface{}) ([]byte, error)

func (*RpcClient) Close ¶

func (this *RpcClient) Close() error

func (*RpcClient) Execute ¶

func (this *RpcClient) Execute(servicePath string, req *handler.RpcRequest) (*handler.RpcResponse, error)

func (*RpcClient) GetAddress ¶

func (this *RpcClient) GetAddress(i int) string

func (*RpcClient) GetPoolUsed ¶

func (this *RpcClient) GetPoolUsed() int64

func (*RpcClient) GoExecute ¶

func (this *RpcClient) GoExecute(servicePath string, req *handler.RpcRequest) (*client.Call, error)

execute rpc method , with whie callback

func (*RpcClient) StreamExecute ¶

func (this *RpcClient) StreamExecute(ctx context.Context, servicePath string, req *handler.RpcRequest, sc StreamCallback) (*handler.RpcResponse, error)

func (RpcServer) ActiveClientConn ¶

func (this RpcServer) ActiveClientConn() []net.Conn

func (*RpcServer) AddPlugin ¶

func (this *RpcServer) AddPlugin(plugin server.Plugin)

func (*RpcServer) RegisterName ¶

func (this *RpcServer) RegisterName(chain *handler.Chain, meta string) error

func (*RpcServer) Run ¶

func (this *RpcServer) Run() error

func (*RpcServer) SendMessage ¶

func (this *RpcServer) SendMessage(conn net.Conn, servicePath string, data []byte) error

send mesage by bidirectional

func (RpcServer) Stop ¶

func (this RpcServer) Stop()