decoder

Documentation

Index

• type Decoder
• type FixedLengthDecoder
  • func NewFixedLengthDecoder(frameLength int) *FixedLengthDecoder
  • func (d *FixedLengthDecoder) Decode(data *[]byte) ([]byte, error)
  • func (d *FixedLengthDecoder) Input(context *event.HandleContext, data interface{}) (interface{}, bool)
• type LengthBased
  • func NewLengthBased(lengthFieldOffset int, lengthFieldLength int, lengthAdjustment int, ...) *LengthBased
  • func (l *LengthBased) Decode(data *[]byte) ([]byte, error)
  • func (l *LengthBased) Input(context *event.HandleContext, data interface{}) (interface{}, bool)

Types

type Decoder

type Decoder interface {
	Decode(data *[]byte) ([]byte, error)
}

Decoder 解码器

type FixedLengthDecoder

type FixedLengthDecoder struct {
	FrameLength int
	// contains filtered or unexported fields
}

func NewFixedLengthDecoder

func NewFixedLengthDecoder(frameLength int) *FixedLengthDecoder

func (*FixedLengthDecoder) Decode

func (d *FixedLengthDecoder) Decode(data *[]byte) ([]byte, error)

func (*FixedLengthDecoder) Input

func (d *FixedLengthDecoder) Input(context *event.HandleContext, data interface{}) (interface{}, bool)

type LengthBased

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

func NewLengthBased

func NewLengthBased(lengthFieldOffset int, lengthFieldLength int, lengthAdjustment int, initialBytesToStrip int) *LengthBased

func (*LengthBased) Decode

func (l *LengthBased) Decode(data *[]byte) ([]byte, error)

func (*LengthBased) Input

func (l *LengthBased) Input(context *event.HandleContext, data interface{}) (interface{}, bool)