Documentation ¶
Index ¶
- Variables
- func Call(sesOrPeer interface{}, reqMsg interface{}, ackMsgName string, ...) error
- func CallSync(ud interface{}, reqMsg interface{}, ackMsgName string, timeout time.Duration) (interface{}, error)
- func ChainSend() *cellnet.HandlerChain
- func NewBoxHandler() cellnet.EventHandler
- func NewReflectCallHandler(userCallback interface{}) cellnet.EventHandler
- func NewRetChanHandler(ret chan interface{}) cellnet.EventHandler
- func NewUnboxHandler(chain *cellnet.HandlerChain) cellnet.EventHandler
- func RegisterMessage(p cellnet.Peer, msgName string, userCallback func(ev *cellnet.Event))
- type BoxHandler
- type RPCSessionGetter
- type ReflectCallHandler
- type RetChanHandler
- type UnboxHandler
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidPeerSession error = errors.New("rpc: Invalid peer type, require cellnet.RPCSessionGetter or cellnet.Session") ErrReplayMessageNotFound = errors.New("rpc: Reply message name not found") MetaCall = cellnet.MessageMetaByName("coredef.RemoteCallACK") )
View Source
var ErrTimeout = errors.New("time out")
Functions ¶
func Call ¶
func Call(sesOrPeer interface{}, reqMsg interface{}, ackMsgName string, timeout time.Duration, userCallback func(ev *cellnet.Event)) error
ud: peer/session, reqMsg:请求用的消息, userCallback: 返回消息类型回调 func( ackMsg *ackMsgType)
func CallSync ¶
func CallSync(ud interface{}, reqMsg interface{}, ackMsgName string, timeout time.Duration) (interface{}, error)
发出请求, 接收到服务器返回后才返回, ud: peer/session, reqMsg:请求用的消息, ackMsgName: 返回消息类型名, 返回消息为返回值
func ChainSend ¶
func ChainSend() *cellnet.HandlerChain
func NewBoxHandler ¶
func NewBoxHandler() cellnet.EventHandler
func NewReflectCallHandler ¶
func NewReflectCallHandler(userCallback interface{}) cellnet.EventHandler
func NewRetChanHandler ¶
func NewRetChanHandler(ret chan interface{}) cellnet.EventHandler
func NewUnboxHandler ¶
func NewUnboxHandler(chain *cellnet.HandlerChain) cellnet.EventHandler
Types ¶
type BoxHandler ¶
type BoxHandler struct { }
func (*BoxHandler) Call ¶
func (self *BoxHandler) Call(ev *cellnet.Event)
type RPCSessionGetter ¶
type ReflectCallHandler ¶
type ReflectCallHandler struct {
// contains filtered or unexported fields
}
func (*ReflectCallHandler) Call ¶
func (self *ReflectCallHandler) Call(ev *cellnet.Event)
type RetChanHandler ¶
type RetChanHandler struct {
// contains filtered or unexported fields
}
func (*RetChanHandler) Call ¶
func (self *RetChanHandler) Call(ev *cellnet.Event)
type UnboxHandler ¶
type UnboxHandler struct {
// contains filtered or unexported fields
}
func (*UnboxHandler) Call ¶
func (self *UnboxHandler) Call(ev *cellnet.Event)
Click to show internal directories.
Click to hide internal directories.