mm_rpc_client

Documentation

Index

• type MRpcClient
  • func (h *MRpcClient) AddConnect(config *model.ServerConfig) error
  • func (h *MRpcClient) AddServerAndConnect(config *model.ServerConfig) error
  • func (h *MRpcClient) ConnectServer() error
  • func (h *MRpcClient) DuplexStream(cfg model.ServerConfig, callBack model.MultRespCallback) (*send.MReqeustSender, error)
  • func (h *MRpcClient) MultRequest(cfg model.ServerConfig) (*send.SReqeustSender, error)
  • func (h *MRpcClient) Request(cfg model.ServerConfig, msgId int32, data []byte) (*model.MsgResp, error)
  • func (h *MRpcClient) RequestMultResp(cfg model.ServerConfig, msgId int32, data []byte, ...) error
  • func (h *MRpcClient) StopConnectServer() error

Types

type MRpcClient

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

func (*MRpcClient) AddConnect

func (h *MRpcClient) AddConnect(config *model.ServerConfig) error

func (*MRpcClient) AddServerAndConnect

func (h *MRpcClient) AddServerAndConnect(config *model.ServerConfig) error

func (*MRpcClient) ConnectServer

func (h *MRpcClient) ConnectServer() error

func (*MRpcClient) DuplexStream

func (h *MRpcClient) DuplexStream(cfg model.ServerConfig, callBack model.MultRespCallback) (*send.MReqeustSender, error)

func (*MRpcClient) MultRequest

func (h *MRpcClient) MultRequest(cfg model.ServerConfig) (*send.SReqeustSender, error)

func (*MRpcClient) Request

func (h *MRpcClient) Request(cfg model.ServerConfig, msgId int32, data []byte) (*model.MsgResp, error)

func (*MRpcClient) RequestMultResp

func (h *MRpcClient) RequestMultResp(cfg model.ServerConfig, msgId int32, data []byte, callback model.MultRespCallback) error

func (*MRpcClient) StopConnectServer

func (h *MRpcClient) StopConnectServer() error