outboundCommands

Documentation

Index

• type ChannelParams
• type ClientRoutineInboundCmdClose
  • func NewClientRoutineInboundCmdClose(uID int64, ChlCtx service.IChannelContext, Desc string) (this *ClientRoutineInboundCmdClose)
  • func (closeEvent *ClientRoutineInboundCmdClose) Exec()
  • func (closeEvent *ClientRoutineInboundCmdClose) QueueId() int64
  • func (closeEvent *ClientRoutineInboundCmdClose) Wait() (result interface{}, ok bool)
• type ClientRoutineInboundCmdConnect
  • func NewClientRoutineInboundCmdConnect(uID int64, ip string, port int, connType connector.SocketType, ...) (this *ClientRoutineInboundCmdConnect)
  • func (upConnectEvent *ClientRoutineInboundCmdConnect) Exec()
  • func (upConnectEvent *ClientRoutineInboundCmdConnect) QueueId() int64
  • func (upConnectEvent *ClientRoutineInboundCmdConnect) Wait() (result interface{}, ok bool)
• type ClientRoutineOutboundCmdMsgSend
  • func NewClientRoutineOutboundCmdMsgSend(Data protocol.IProtocol, OnClose bool, PoolKey int64, ...) (this *ClientRoutineOutboundCmdMsgSend)
  • func (msgSendEvent *ClientRoutineOutboundCmdMsgSend) Exec()
  • func (msgSendEvent *ClientRoutineOutboundCmdMsgSend) QueueId() int64
  • func (msgSendEvent *ClientRoutineOutboundCmdMsgSend) Wait() (result interface{}, ok bool)

Types

type ChannelParams

type ChannelParams struct {
	Uid   int64
	Token string
}

type ClientRoutineInboundCmdClose

type ClientRoutineInboundCmdClose struct {
	ChlCtx service.IChannelContext
	Desc   string
	// contains filtered or unexported fields
}

func NewClientRoutineInboundCmdClose

func NewClientRoutineInboundCmdClose(uID int64, ChlCtx service.IChannelContext, Desc string) (this *ClientRoutineInboundCmdClose)

func (*ClientRoutineInboundCmdClose) Exec

func (closeEvent *ClientRoutineInboundCmdClose) Exec()

func (*ClientRoutineInboundCmdClose) QueueId

func (closeEvent *ClientRoutineInboundCmdClose) QueueId() int64

func (*ClientRoutineInboundCmdClose) Wait

func (closeEvent *ClientRoutineInboundCmdClose) Wait() (result interface{}, ok bool)

type ClientRoutineInboundCmdConnect

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

func NewClientRoutineInboundCmdConnect

func NewClientRoutineInboundCmdConnect(uID int64, ip string, port int, connType connector.SocketType,
	params map[string]interface{},
	connector listener.IConnector, callback inboundCommands.ICallBack) (this *ClientRoutineInboundCmdConnect)

func (*ClientRoutineInboundCmdConnect) Exec

func (upConnectEvent *ClientRoutineInboundCmdConnect) Exec()

func (*ClientRoutineInboundCmdConnect) QueueId

func (upConnectEvent *ClientRoutineInboundCmdConnect) QueueId() int64

func (*ClientRoutineInboundCmdConnect) Wait

func (upConnectEvent *ClientRoutineInboundCmdConnect) Wait() (result interface{}, ok bool)

type ClientRoutineOutboundCmdMsgSend

type ClientRoutineOutboundCmdMsgSend struct {
	Data    protocol.IProtocol
	OnClose bool // 是否在消息发送完毕后关闭连接
	PoolKey int64
	ChlCtx  service.IChannelContext
	Desc    string
}

func NewClientRoutineOutboundCmdMsgSend

func NewClientRoutineOutboundCmdMsgSend(Data protocol.IProtocol, OnClose bool, PoolKey int64, ChlCtx service.IChannelContext, Desc string) (this *ClientRoutineOutboundCmdMsgSend)

func (*ClientRoutineOutboundCmdMsgSend) Exec

func (msgSendEvent *ClientRoutineOutboundCmdMsgSend) Exec()

func (*ClientRoutineOutboundCmdMsgSend) QueueId

func (msgSendEvent *ClientRoutineOutboundCmdMsgSend) QueueId() int64

func (*ClientRoutineOutboundCmdMsgSend) Wait

func (msgSendEvent *ClientRoutineOutboundCmdMsgSend) Wait() (result interface{}, ok bool)