inboundCommands

Documentation

Index

• type ClientChannelUpActiveEvent
  • func NewClientChannelUpActiveEvent(routineId int64, mEventMaker schedule.IRoutineInboundEventMaker, ...) (this *ClientChannelUpActiveEvent)
  • func (activeEvent *ClientChannelUpActiveEvent) Exec()
  • func (activeEvent *ClientChannelUpActiveEvent) QueueId() int64
  • func (activeEvent *ClientChannelUpActiveEvent) Wait() (result interface{}, ok bool)
• type ClientChannelUpActiveFailEvent
  • func NewClientChannelUpActiveFailEvent(routineId int64, callback ICallBack, err error, params map[string]interface{}) (this *ClientChannelUpActiveFailEvent)
  • func (activeEvent *ClientChannelUpActiveFailEvent) Exec()
  • func (activeEvent *ClientChannelUpActiveFailEvent) QueueId() int64
  • func (activeEvent *ClientChannelUpActiveFailEvent) Wait() (result interface{}, ok bool)
• type ClientChannelUpMsgRecvEvent
  • func NewClientChannelUpMsgRecvEvent(routineId int64, Data protocol.IProtocol, Ctx service.IChannelContext, ...) (this *ClientChannelUpMsgRecvEvent)
  • func (msgRecvEvent *ClientChannelUpMsgRecvEvent) Exec()
  • func (msgRecvEvent *ClientChannelUpMsgRecvEvent) QueueId() int64
  • func (msgRecvEvent *ClientChannelUpMsgRecvEvent) Wait() (result interface{}, ok bool)
• type ClientRoutineInboundCmdInactive
  • func NewClientRoutineInboundCmdInactive(routineId int64, ChlCtx service.IChannelContext, callback ICallBack) (this *ClientRoutineInboundCmdInactive)
  • func (inactiveEvent *ClientRoutineInboundCmdInactive) Exec()
  • func (inactiveEvent *ClientRoutineInboundCmdInactive) QueueId() int64
  • func (inactiveEvent *ClientRoutineInboundCmdInactive) Wait() (result interface{}, ok bool)
• type ICallBack

Types

type ClientChannelUpActiveEvent

type ClientChannelUpActiveEvent struct {
	ChlCtx service.IChannelContext
	// contains filtered or unexported fields
}

func NewClientChannelUpActiveEvent

func NewClientChannelUpActiveEvent(routineId int64,
	mEventMaker schedule.IRoutineInboundEventMaker, ChlCtx service.IChannelContext, callback ICallBack) (this *ClientChannelUpActiveEvent)

func (*ClientChannelUpActiveEvent) Exec

func (activeEvent *ClientChannelUpActiveEvent) Exec()

func (*ClientChannelUpActiveEvent) QueueId

func (activeEvent *ClientChannelUpActiveEvent) QueueId() int64

func (*ClientChannelUpActiveEvent) Wait

func (activeEvent *ClientChannelUpActiveEvent) Wait() (result interface{}, ok bool)

type ClientChannelUpActiveFailEvent

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

func NewClientChannelUpActiveFailEvent

func NewClientChannelUpActiveFailEvent(routineId int64, callback ICallBack, err error, params map[string]interface{}) (this *ClientChannelUpActiveFailEvent)

func (*ClientChannelUpActiveFailEvent) Exec

func (activeEvent *ClientChannelUpActiveFailEvent) Exec()

func (*ClientChannelUpActiveFailEvent) QueueId

func (activeEvent *ClientChannelUpActiveFailEvent) QueueId() int64

func (*ClientChannelUpActiveFailEvent) Wait

func (activeEvent *ClientChannelUpActiveFailEvent) Wait() (result interface{}, ok bool)

type ClientChannelUpMsgRecvEvent

type ClientChannelUpMsgRecvEvent struct {
	Data protocol.IProtocol
	Ctx  service.IChannelContext
	// contains filtered or unexported fields
}

func NewClientChannelUpMsgRecvEvent

func NewClientChannelUpMsgRecvEvent(routineId int64, Data protocol.IProtocol,
	Ctx service.IChannelContext, mEventMaker schedule.IRoutineInboundEventMaker, callback ICallBack) (this *ClientChannelUpMsgRecvEvent)

func (*ClientChannelUpMsgRecvEvent) Exec

func (msgRecvEvent *ClientChannelUpMsgRecvEvent) Exec()

func (*ClientChannelUpMsgRecvEvent) QueueId

func (msgRecvEvent *ClientChannelUpMsgRecvEvent) QueueId() int64

func (*ClientChannelUpMsgRecvEvent) Wait

func (msgRecvEvent *ClientChannelUpMsgRecvEvent) Wait() (result interface{}, ok bool)

type ClientRoutineInboundCmdInactive

type ClientRoutineInboundCmdInactive struct {
	ChlCtx service.IChannelContext
	// contains filtered or unexported fields
}

func NewClientRoutineInboundCmdInactive

func NewClientRoutineInboundCmdInactive(routineId int64,
	ChlCtx service.IChannelContext, callback ICallBack) (this *ClientRoutineInboundCmdInactive)

func (*ClientRoutineInboundCmdInactive) Exec

func (inactiveEvent *ClientRoutineInboundCmdInactive) Exec()

func (*ClientRoutineInboundCmdInactive) QueueId

func (inactiveEvent *ClientRoutineInboundCmdInactive) QueueId() int64

func (*ClientRoutineInboundCmdInactive) Wait

func (inactiveEvent *ClientRoutineInboundCmdInactive) Wait() (result interface{}, ok bool)

type ICallBack

type ICallBack interface {
	ConnectSuccess(uID int64, currentChlCtx service.IChannelContext)
	ConnectFail(err error, params map[string]interface{})
	ConnectInactive(uID int64, currentChlCtx service.IChannelContext)
	MessageReceived(Ctx service.IChannelContext, Data protocol.IProtocol)
}