Documentation ¶
Index ¶
- type MsgpackCodec
- type RpcClient
- func (this *RpcClient) Close() error
- func (this *RpcClient) Execute(servicePath string, req *handler.RpcRequest) (*handler.RpcResponse, error)
- func (this *RpcClient) GetAddress(i int) string
- func (this *RpcClient) GetPoolUsed() int64
- func (this *RpcClient) GoExecute(servicePath string, req *handler.RpcRequest) (*client.Call, error)
- func (this *RpcClient) StreamExecute(ctx context.Context, servicePath string, req *handler.RpcRequest, ...) (*handler.RpcResponse, error)
- type RpcServer
- func (this RpcServer) ActiveClientConn() []net.Conn
- func (this *RpcServer) AddPlugin(plugin server.Plugin)
- func (this *RpcServer) RegisterName(chain *handler.Chain, meta string) error
- func (this *RpcServer) Run() error
- func (this *RpcServer) SendMessage(conn net.Conn, servicePath string, data []byte) error
- func (this RpcServer) Stop()
- type StreamCallback
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MsgpackCodec ¶
type MsgpackCodec struct { }
func (*MsgpackCodec) Decode ¶
func (c *MsgpackCodec) Decode(data []byte, i interface{}) error
func (*MsgpackCodec) Encode ¶
func (c *MsgpackCodec) Encode(i interface{}) ([]byte, error)
type RpcClient ¶
type RpcClient struct {
// contains filtered or unexported fields
}
func NewRpcClient ¶
client *client.OneClient
func (*RpcClient) Execute ¶
func (this *RpcClient) Execute(servicePath string, req *handler.RpcRequest) (*handler.RpcResponse, error)
func (*RpcClient) GetAddress ¶
func (*RpcClient) GetPoolUsed ¶
func (*RpcClient) StreamExecute ¶
func (this *RpcClient) StreamExecute(ctx context.Context, servicePath string, req *handler.RpcRequest, sc StreamCallback) (*handler.RpcResponse, error)
type RpcServer ¶
type RpcServer struct {
// contains filtered or unexported fields
}
func NewRpcServer ¶
func (RpcServer) ActiveClientConn ¶
func (*RpcServer) RegisterName ¶
func (*RpcServer) SendMessage ¶
send mesage by bidirectional
type StreamCallback ¶
Click to show internal directories.
Click to hide internal directories.