routineCmdMakerImpl

Documentation

Index

• func NewRoutineInboundCmdMaker() schedule.IRoutineInboundEventMaker
• type RoutineInboundCmdMaker
  • func (impl *RoutineInboundCmdMaker) MakeActiveEvent(routineId int64, Ctx service.IChannelContext) executor.Event
  • func (impl *RoutineInboundCmdMaker) MakeInActiveEvent(routineId int64, Ctx service.IChannelContext) executor.Event
  • func (impl *RoutineInboundCmdMaker) MakeMessageReceivedEvent(routineId int64, Data protocol.Protocol, Ctx service.IChannelContext) executor.Event
• type RoutineOutboundCmdMaker
  • func NewRoutineOutboundCmdMaker() (impl *RoutineOutboundCmdMaker)
  • func (impl *RoutineOutboundCmdMaker) MakeCloseEvent(routineId int64, uID int64, Desc string) executor.Event
  • func (impl *RoutineOutboundCmdMaker) MakeConnectEvent(routineId int64, ip string, port int, uID int64, params map[string]interface{}) executor.Event
  • func (impl *RoutineOutboundCmdMaker) MakeSendMessageEvent(routineId int64, Data protocol.Protocol, OnClose bool, PoolKey int64, ...) executor.Event

Functions

func NewRoutineInboundCmdMaker

func NewRoutineInboundCmdMaker() schedule.IRoutineInboundEventMaker

Types

type RoutineInboundCmdMaker

type RoutineInboundCmdMaker struct {
}

func (*RoutineInboundCmdMaker) MakeActiveEvent

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

新连接

func (*RoutineInboundCmdMaker) MakeInActiveEvent

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

连接中断

func (*RoutineInboundCmdMaker) MakeMessageReceivedEvent

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

收到消息包

type RoutineOutboundCmdMaker

type RoutineOutboundCmdMaker struct {
}

func NewRoutineOutboundCmdMaker

func NewRoutineOutboundCmdMaker() (impl *RoutineOutboundCmdMaker)

func (*RoutineOutboundCmdMaker) MakeCloseEvent

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

func (*RoutineOutboundCmdMaker) MakeConnectEvent

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

func (*RoutineOutboundCmdMaker) MakeSendMessageEvent

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