channelCmdMakerImpl

Documentation

Index

• type ClientInboundCommandMaker
  • func NewClientInboundCommandMaker(mEventMaker schedule.IRoutineInboundEventMaker) (impl *ClientInboundCommandMaker)
  • func (impl *ClientInboundCommandMaker) MakeActiveCommand(Ctx service.IChannelContext) schedule.ICommand
  • func (impl *ClientInboundCommandMaker) MakeExceptionCommand(ctx service.IChannelContext, err error) schedule.ICommand
  • func (impl *ClientInboundCommandMaker) MakeInActiveCommand(Ctx service.IChannelContext) schedule.ICommand
  • func (impl *ClientInboundCommandMaker) MakeMessageReceivedCommand(Ctx service.IChannelContext, Data interface{}) schedule.ICommand
• type ClientOutboundCommandMaker
  • func NewClientOutboundCommandMaker() (impl *ClientOutboundCommandMaker)
  • func (impl *ClientOutboundCommandMaker) MakeCloseCommand(Ctx channel.ChannelContext) schedule.ICommand
  • func (impl *ClientOutboundCommandMaker) MakeExceptionCommand(ctx channel.ChannelContext, err error) schedule.ICommand
  • func (impl *ClientOutboundCommandMaker) MakeMessageSendCommand(Ctx channel.ChannelContext, Data interface{}) schedule.ICommand

Types

type ClientInboundCommandMaker

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

func NewClientInboundCommandMaker

func NewClientInboundCommandMaker(mEventMaker schedule.IRoutineInboundEventMaker) (impl *ClientInboundCommandMaker)

func (*ClientInboundCommandMaker) MakeActiveCommand

func (impl *ClientInboundCommandMaker) MakeActiveCommand(Ctx service.IChannelContext) schedule.ICommand

新连接

func (*ClientInboundCommandMaker) MakeExceptionCommand

func (impl *ClientInboundCommandMaker) MakeExceptionCommand(ctx service.IChannelContext, err error) schedule.ICommand

触发异常

func (*ClientInboundCommandMaker) MakeInActiveCommand

func (impl *ClientInboundCommandMaker) MakeInActiveCommand(Ctx service.IChannelContext) schedule.ICommand

连接中断

func (*ClientInboundCommandMaker) MakeMessageReceivedCommand

func (impl *ClientInboundCommandMaker) MakeMessageReceivedCommand(Ctx service.IChannelContext, Data interface{}) schedule.ICommand

收到消息包

type ClientOutboundCommandMaker

type ClientOutboundCommandMaker struct {
}

func NewClientOutboundCommandMaker

func NewClientOutboundCommandMaker() (impl *ClientOutboundCommandMaker)

func (*ClientOutboundCommandMaker) MakeCloseCommand

func (impl *ClientOutboundCommandMaker) MakeCloseCommand(Ctx channel.ChannelContext) schedule.ICommand

请求关闭连接

func (*ClientOutboundCommandMaker) MakeExceptionCommand

func (impl *ClientOutboundCommandMaker) MakeExceptionCommand(ctx channel.ChannelContext, err error) schedule.ICommand

触发异常

func (*ClientOutboundCommandMaker) MakeMessageSendCommand

func (impl *ClientOutboundCommandMaker) MakeMessageSendCommand(Ctx channel.ChannelContext, Data interface{}) schedule.ICommand

下发消息包