Versions in this module Expand all Collapse all v1 v1.0.0 Nov 13, 2018 Changes in this version + var ErrEmptySession = errors.New("rpc: Empty session") + var ErrInvalidPeerSession = errors.New("rpc: Invalid peer type, require cellnet.RPCSessionGetter or cellnet.Session") + var ErrTimeout = errors.New("RPC time out") + func Call(sesOrPeer interface{}, reqMsg interface{}, timeout time.Duration, ...) + func CallSync(ud interface{}, reqMsg interface{}, timeout time.Duration) (interface{}, error) + func ResolveInboundEvent(inputEvent cellnet.Event) (ouputEvent cellnet.Event, handled bool, err error) + func ResolveOutboundEvent(inputEvent cellnet.Event) (handled bool, err error) + type RPCSessionGetter interface + RPCSession func() cellnet.Session + type RecvMsgEvent struct + Msg interface{} + func (self *RecvMsgEvent) Message() interface{} + func (self *RecvMsgEvent) Queue() cellnet.EventQueue + func (self *RecvMsgEvent) Reply(msg interface{}) + func (self *RecvMsgEvent) Session() cellnet.Session + type RemoteCallACK struct + CallID int64 + Data []byte + MsgID uint16 + func (self *RemoteCallACK) GetCallID() int64 + func (self *RemoteCallACK) GetMsgData() []byte + func (self *RemoteCallACK) GetMsgID() uint16 + func (self *RemoteCallACK) String() string + type RemoteCallMsg interface + GetCallID func() int64 + GetMsgData func() []byte + GetMsgID func() uint16 + type RemoteCallREQ struct + CallID int64 + Data []byte + MsgID uint16 + func (self *RemoteCallREQ) GetCallID() int64 + func (self *RemoteCallREQ) GetMsgData() []byte + func (self *RemoteCallREQ) GetMsgID() uint16 + func (self *RemoteCallREQ) String() string
Go to main page