rpc

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
  • func (self *BoxHandler) Call(ev *cellnet.Event)
• type RPCSessionGetter
• type ReflectCallHandler
  • func (self *ReflectCallHandler) Call(ev *cellnet.Event)
• type RetChanHandler
  • func (self *RetChanHandler) Call(ev *cellnet.Event)
• type UnboxHandler
  • func (self *UnboxHandler) Call(ev *cellnet.Event)

Variables

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")
)

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

func RegisterMessage

func RegisterMessage(p cellnet.Peer, msgName string, userCallback func(ev *cellnet.Event))

服务器端响应RPC消息

Types

type BoxHandler

type BoxHandler struct {
}

func (*BoxHandler) Call

func (self *BoxHandler) Call(ev *cellnet.Event)

type RPCSessionGetter

type RPCSessionGetter interface {
	RPCSession() cellnet.Session
}

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)