channelCommands

Documentation

Index

• type ChannelInboundCmdMsgRecv
  • func NewChannelInboundCmdMsgRecv(mEventMaker schedule.IRoutineInboundEventMaker, ...) (this *ChannelInboundCmdMsgRecv)
  • func (event *ChannelInboundCmdMsgRecv) Exec()
• type ILoginMessage
• type ServerCommandActive
  • func NewServerCommandActive(ChannelCtx service.IChannelContext) (this *ServerCommandActive)
  • func (event *ServerCommandActive) Exec()
• type ServerCommandException
  • func NewServerCommandException(ChannelCtx service.IChannelContext, err error) (this *ServerCommandException)
  • func (event *ServerCommandException) Exec()
• type ServerCommandInActive
  • func NewServerCommandInActive(mEventMaker schedule.IRoutineInboundEventMaker, ...) (this *ServerCommandInActive)
  • func (event *ServerCommandInActive) Exec()

Types

type ChannelInboundCmdMsgRecv

type ChannelInboundCmdMsgRecv struct {
	ChannelCtx service.IChannelContext
	// contains filtered or unexported fields
}

func NewChannelInboundCmdMsgRecv

func NewChannelInboundCmdMsgRecv(
	mEventMaker schedule.IRoutineInboundEventMaker, ChannelCtx service.IChannelContext, e interface{}, mLoginMessage ILoginMessage) (this *ChannelInboundCmdMsgRecv)

func (*ChannelInboundCmdMsgRecv) Exec

func (event *ChannelInboundCmdMsgRecv) Exec()

type ILoginMessage

type ILoginMessage interface {
	IsLoginMessage(msg *message.Message) bool
	IsValid(msg *message.Message) bool
	GetLoginUID(msg *message.Message) int64
	GetLngType(msg *message.Message) int8
}

一条socket链接建立以后，发送给服务端的第一条消息必须实现该接口，用于分配处理该链接的协程

type ServerCommandActive

type ServerCommandActive struct {
	ChannelCtx service.IChannelContext
}

func NewServerCommandActive

func NewServerCommandActive(ChannelCtx service.IChannelContext) (this *ServerCommandActive)

func (*ServerCommandActive) Exec

func (event *ServerCommandActive) Exec()

type ServerCommandException

type ServerCommandException struct {
	ChannelCtx service.IChannelContext
	// contains filtered or unexported fields
}

func NewServerCommandException

func NewServerCommandException(ChannelCtx service.IChannelContext, err error) (this *ServerCommandException)

func (*ServerCommandException) Exec

func (event *ServerCommandException) Exec()

type ServerCommandInActive

type ServerCommandInActive struct {
	ChannelCtx service.IChannelContext
	// contains filtered or unexported fields
}

func NewServerCommandInActive

func NewServerCommandInActive(
	mEventMaker schedule.IRoutineInboundEventMaker, ChannelCtx service.IChannelContext) (this *ServerCommandInActive)

func (*ServerCommandInActive) Exec

func (event *ServerCommandInActive) Exec()