routineCmdMakerImpl

Documentation

Index

• type ClientInboundEventMakerImpl
  • func NewClientInboundEventMakerImpl(connector listener.IConnector, callback routineCommands.ICallBack) (impl *ClientInboundEventMakerImpl)
  • func (impl *ClientInboundEventMakerImpl) MakeActiveEvent(routineId int64, Ctx service.IChannelContext) executor.Event
  • func (impl *ClientInboundEventMakerImpl) MakeInActiveEvent(routineId int64, Ctx service.IChannelContext) executor.Event
  • func (impl *ClientInboundEventMakerImpl) MakeMessageReceivedEvent(routineId int64, Data protocol.IProtocol, Ctx service.IChannelContext) executor.Event
• type ClientOutboundEventMaker
  • func NewClientOutboundEventMaker(connector listener.IConnector) (impl *ClientOutboundEventMaker)
  • func (impl *ClientOutboundEventMaker) MakeCloseEvent(routineId int64, uID int64, Desc string) executor.Event
  • func (impl *ClientOutboundEventMaker) MakeConnectEvent(routineId int64, ip string, port int, uID int64, params map[string]interface{}) executor.Event
  • func (impl *ClientOutboundEventMaker) MakeSendMessageEvent(routineId int64, Data protocol.IProtocol, OnClose bool, PoolKey int64, ...) executor.Event

Types

type ClientInboundEventMakerImpl

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

func NewClientInboundEventMakerImpl

func NewClientInboundEventMakerImpl(connector listener.IConnector, callback routineCommands.ICallBack) (impl *ClientInboundEventMakerImpl)

func (*ClientInboundEventMakerImpl) MakeActiveEvent

func (impl *ClientInboundEventMakerImpl) MakeActiveEvent(routineId int64, Ctx service.IChannelContext) executor.Event

新连接

func (*ClientInboundEventMakerImpl) MakeInActiveEvent

func (impl *ClientInboundEventMakerImpl) MakeInActiveEvent(routineId int64, Ctx service.IChannelContext) executor.Event

连接中断

func (*ClientInboundEventMakerImpl) MakeMessageReceivedEvent

func (impl *ClientInboundEventMakerImpl) MakeMessageReceivedEvent(routineId int64, Data protocol.IProtocol, Ctx service.IChannelContext) executor.Event

收到消息包

type ClientOutboundEventMaker

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

func NewClientOutboundEventMaker

func NewClientOutboundEventMaker(connector listener.IConnector) (impl *ClientOutboundEventMaker)

func (*ClientOutboundEventMaker) MakeCloseEvent

func (impl *ClientOutboundEventMaker) MakeCloseEvent(routineId int64, uID int64, Desc string) executor.Event

func (*ClientOutboundEventMaker) MakeConnectEvent

func (impl *ClientOutboundEventMaker) MakeConnectEvent(routineId int64, ip string, port int, uID int64, params map[string]interface{}) executor.Event

func (*ClientOutboundEventMaker) MakeSendMessageEvent

func (impl *ClientOutboundEventMaker) MakeSendMessageEvent(routineId int64, Data protocol.IProtocol, OnClose bool, PoolKey int64, ChlCtx service.IChannelContext, Desc string) executor.Event