encodernocache

Documentation

Index

• Constants
• Variables
• type AvroXEncoder
  • func (pb *AvroXEncoder) Decode(_ string, data []byte, vPtr interface{}) error
  • func (pb *AvroXEncoder) Encode(_ string, v interface{}) ([]byte, error)

Constants

const (
	AVROX_ENCODER = "avrox"
)

Variables

var (
	ErrInvalidAvroXMsgEncode = errors.New("nats: Invalid avrox object passed to encode")
	ErrInvalidAvroXMsgDecode = errors.New("nats: Invalid avrox object passed to decode")
)

Types

type AvroXEncoder

type AvroXEncoder struct {
	Compression avrox.CompressionID
}

AvroXEncoder is a AvroX implementation for EncodedConn We use an alternative cache to the default one though

func (*AvroXEncoder) Decode

func (pb *AvroXEncoder) Decode(_ string, data []byte, vPtr interface{}) error

Decode

func (*AvroXEncoder) Encode

func (pb *AvroXEncoder) Encode(_ string, v interface{}) ([]byte, error)

Encode