decoding

Documentation

Index

• type AvroMessageDecoder
  • func (amd *AvroMessageDecoder) Decode(val []byte) (interface{}, error)
• type JSONExtMessageDecoder
  • func (jmd *JSONExtMessageDecoder) Decode(val []byte) (interface{}, error)
• type JSONMessageDecoder
  • func (jmd *JSONMessageDecoder) Decode(val []byte) (interface{}, error)
• type MessageDecoder

Types

type AvroMessageDecoder

type AvroMessageDecoder struct {
	SchemaSpec string
	Binary     bool
}

func (*AvroMessageDecoder) Decode

func (amd *AvroMessageDecoder) Decode(val []byte) (interface{}, error)

type JSONExtMessageDecoder

type JSONExtMessageDecoder struct{}

func (*JSONExtMessageDecoder) Decode

func (jmd *JSONExtMessageDecoder) Decode(val []byte) (interface{}, error)

type JSONMessageDecoder

type JSONMessageDecoder struct{}

func (*JSONMessageDecoder) Decode

func (jmd *JSONMessageDecoder) Decode(val []byte) (interface{}, error)

type MessageDecoder

type MessageDecoder interface {
	Decode([]byte) (interface{}, error)
}