routineCommands

Documentation

Index

• type RoutineInboundCmdInactive
  • func NewRoutineInboundCmdInactive(routineId int64, ChlCtx service.IChannelContext) (this *RoutineInboundCmdInactive)
  • func (event *RoutineInboundCmdInactive) Exec()
  • func (event *RoutineInboundCmdInactive) QueueId() int64
  • func (event *RoutineInboundCmdInactive) Wait() (interface{}, bool)
• type RoutineInboundCmdMsgRecv
  • func NewRoutineInboundCmdMsgRecv(routineId int64, Data protocol.IProtocol, Ctx service.IChannelContext) (this *RoutineInboundCmdMsgRecv)
  • func (event *RoutineInboundCmdMsgRecv) Exec()
  • func (event *RoutineInboundCmdMsgRecv) QueueId() int64
  • func (event *RoutineInboundCmdMsgRecv) Wait() (interface{}, bool)
• type ServerRoutineOutboundCmdMsgSend
  • func NewServerRoutineOutboundCmdMsgSend(routineId int64, Data protocol.IProtocol, OnClose bool, PoolKey int64, ...) (this *ServerRoutineOutboundCmdMsgSend)
  • func (this *ServerRoutineOutboundCmdMsgSend) Exec()
  • func (this *ServerRoutineOutboundCmdMsgSend) QueueId() int64
  • func (this *ServerRoutineOutboundCmdMsgSend) Wait() (interface{}, bool)

Types

type RoutineInboundCmdInactive

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

func NewRoutineInboundCmdInactive

func NewRoutineInboundCmdInactive(routineId int64, ChlCtx service.IChannelContext) (this *RoutineInboundCmdInactive)

func (*RoutineInboundCmdInactive) Exec

func (event *RoutineInboundCmdInactive) Exec()

func (*RoutineInboundCmdInactive) QueueId

func (event *RoutineInboundCmdInactive) QueueId() int64

func (*RoutineInboundCmdInactive) Wait

func (event *RoutineInboundCmdInactive) Wait() (interface{}, bool)

type RoutineInboundCmdMsgRecv

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

func NewRoutineInboundCmdMsgRecv

func NewRoutineInboundCmdMsgRecv(routineId int64, Data protocol.IProtocol,
	Ctx service.IChannelContext) (this *RoutineInboundCmdMsgRecv)

func (*RoutineInboundCmdMsgRecv) Exec

func (event *RoutineInboundCmdMsgRecv) Exec()

func (*RoutineInboundCmdMsgRecv) QueueId

func (event *RoutineInboundCmdMsgRecv) QueueId() int64

func (*RoutineInboundCmdMsgRecv) Wait

func (event *RoutineInboundCmdMsgRecv) Wait() (interface{}, bool)

type ServerRoutineOutboundCmdMsgSend

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

func NewServerRoutineOutboundCmdMsgSend

func NewServerRoutineOutboundCmdMsgSend(routineId int64, Data protocol.IProtocol, OnClose bool, PoolKey int64, ChlCtx service.IChannelContext, Desc string) (this *ServerRoutineOutboundCmdMsgSend)

func (*ServerRoutineOutboundCmdMsgSend) Exec

func (this *ServerRoutineOutboundCmdMsgSend) Exec()

func (*ServerRoutineOutboundCmdMsgSend) QueueId

func (this *ServerRoutineOutboundCmdMsgSend) QueueId() int64

func (*ServerRoutineOutboundCmdMsgSend) Wait

func (this *ServerRoutineOutboundCmdMsgSend) Wait() (interface{}, bool)