code

Documentation

Index

• Constants
• type MessageDecoderHandleOnRoutineSync
  • func NewMessageDecoderHandleOnRoutineSync(messageFactory protocol.ProtocolFactory) (this *MessageDecoderHandleOnRoutineSync)
  • func (decoder *MessageDecoderHandleOnRoutineSync) ChannelActive(ctx channel.ChannelContext) (goonNext bool)
  • func (decoder *MessageDecoderHandleOnRoutineSync) ChannelInactive(ctx channel.ChannelContext) (goonNext bool)
  • func (decoder *MessageDecoderHandleOnRoutineSync) ExceptionCaught(ctx channel.ChannelContext, err error)
  • func (decoder *MessageDecoderHandleOnRoutineSync) MessageReceived(ctx channel.ChannelContext, e interface{}) (ret interface{}, goonNext bool)
• type MessageEncoderHandleOnRoutineSync
  • func NewMessageEncoderHandleOnRoutineSync() (this *MessageEncoderHandleOnRoutineSync)
  • func (encoder *MessageEncoderHandleOnRoutineSync) Close(ctx channel.ChannelContext)
  • func (encoder *MessageEncoderHandleOnRoutineSync) ExceptionCaught(ctx channel.ChannelContext, err error)
  • func (encoder *MessageEncoderHandleOnRoutineSync) Write(ctx channel.ChannelContext, e interface{}) (ret interface{})
• type SecurityDecoderHandler
  • func NewSecurityDecoderHandler() (this *SecurityDecoderHandler)
  • func (decoder *SecurityDecoderHandler) ChannelActive(ctx channel.ChannelContext) (goonNext bool)
  • func (decoder *SecurityDecoderHandler) ChannelInactive(ctx channel.ChannelContext) (goonNext bool)
  • func (decoder *SecurityDecoderHandler) ExceptionCaught(ctx channel.ChannelContext, err error)
  • func (decoder *SecurityDecoderHandler) MessageReceived(ctx channel.ChannelContext, e interface{}) (ret interface{}, goonNext bool)
• type SecurityEncoderHandler
  • func NewSecurityEncoderHandler() (this *SecurityEncoderHandler)
  • func (encoder *SecurityEncoderHandler) Close(ctx channel.ChannelContext)
  • func (encoder *SecurityEncoderHandler) ExceptionCaught(ctx channel.ChannelContext, err error)
  • func (encoder *SecurityEncoderHandler) Write(ctx channel.ChannelContext, e interface{}) (ret interface{})

Constants

const (
	ChannelSecurityType string = "ChannelSecurityType" //string
)

Types

type MessageDecoderHandleOnRoutineSync

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

*buffer.ProtocolBuffer ---> UpBase

func NewMessageDecoderHandleOnRoutineSync

func NewMessageDecoderHandleOnRoutineSync(messageFactory protocol.ProtocolFactory) (this *MessageDecoderHandleOnRoutineSync)

func (*MessageDecoderHandleOnRoutineSync) ChannelActive

func (decoder *MessageDecoderHandleOnRoutineSync) ChannelActive(ctx channel.ChannelContext) (goonNext bool)

func (*MessageDecoderHandleOnRoutineSync) ChannelInactive

func (decoder *MessageDecoderHandleOnRoutineSync) ChannelInactive(ctx channel.ChannelContext) (goonNext bool)

func (*MessageDecoderHandleOnRoutineSync) ExceptionCaught

func (decoder *MessageDecoderHandleOnRoutineSync) ExceptionCaught(ctx channel.ChannelContext, err error)

func (*MessageDecoderHandleOnRoutineSync) MessageReceived

func (decoder *MessageDecoderHandleOnRoutineSync) MessageReceived(ctx channel.ChannelContext, e interface{}) (ret interface{}, goonNext bool)

type MessageEncoderHandleOnRoutineSync

type MessageEncoderHandleOnRoutineSync struct {
}

DownBase ---> *buffer.ProtocolBuffer

func NewMessageEncoderHandleOnRoutineSync

func NewMessageEncoderHandleOnRoutineSync() (this *MessageEncoderHandleOnRoutineSync)

func (*MessageEncoderHandleOnRoutineSync) Close

func (encoder *MessageEncoderHandleOnRoutineSync) Close(ctx channel.ChannelContext)

func (*MessageEncoderHandleOnRoutineSync) ExceptionCaught

func (encoder *MessageEncoderHandleOnRoutineSync) ExceptionCaught(ctx channel.ChannelContext, err error)

func (*MessageEncoderHandleOnRoutineSync) Write

func (encoder *MessageEncoderHandleOnRoutineSync) Write(ctx channel.ChannelContext, e interface{}) (ret interface{})

type SecurityDecoderHandler

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

[]byte-->*ProtocolBuffer

func NewSecurityDecoderHandler

func NewSecurityDecoderHandler() (this *SecurityDecoderHandler)

func (*SecurityDecoderHandler) ChannelActive

func (decoder *SecurityDecoderHandler) ChannelActive(ctx channel.ChannelContext) (goonNext bool)

func (*SecurityDecoderHandler) ChannelInactive

func (decoder *SecurityDecoderHandler) ChannelInactive(ctx channel.ChannelContext) (goonNext bool)

func (*SecurityDecoderHandler) ExceptionCaught

func (decoder *SecurityDecoderHandler) ExceptionCaught(ctx channel.ChannelContext, err error)

func (*SecurityDecoderHandler) MessageReceived

func (decoder *SecurityDecoderHandler) MessageReceived(ctx channel.ChannelContext, e interface{}) (ret interface{}, goonNext bool)

type SecurityEncoderHandler

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

*ProtocolBuffer-->*ProtocolBuffer

func NewSecurityEncoderHandler

func NewSecurityEncoderHandler() (this *SecurityEncoderHandler)

func (*SecurityEncoderHandler) Close

func (encoder *SecurityEncoderHandler) Close(ctx channel.ChannelContext)

func (*SecurityEncoderHandler) ExceptionCaught

func (encoder *SecurityEncoderHandler) ExceptionCaught(ctx channel.ChannelContext, err error)

func (*SecurityEncoderHandler) Write

func (encoder *SecurityEncoderHandler) Write(ctx channel.ChannelContext, e interface{}) (ret interface{})