Versions in this module Expand all Collapse all v1 v1.6.8 Feb 25, 2022 v1.6.7 Feb 25, 2022 Changes in this version + var HeaderSchema = avro.MustParse(...) + type Codec interface + Decode func([]byte) ([]byte, error) + Encode func([]byte) []byte + type CodecName string + const Deflate + const Null + const Snappy + type Decoder struct + func NewDecoder(r io.Reader) (*Decoder, error) + func (d *Decoder) Decode(v interface{}) error + func (d *Decoder) Error() error + func (d *Decoder) HasNext() bool + func (d *Decoder) Metadata() map[string][]byte + type DeflateCodec struct + func (*DeflateCodec) Decode(b []byte) ([]byte, error) + func (*DeflateCodec) Encode(b []byte) []byte + type Encoder struct + func NewEncoder(s string, w io.Writer, opts ...EncoderFunc) (*Encoder, error) + func (e *Encoder) Close() error + func (e *Encoder) Encode(v interface{}) error + func (e *Encoder) Flush() error + func (e *Encoder) Write(p []byte) (n int, err error) + type EncoderFunc func(cfg *encoderConfig) + func WithBlockLength(length int) EncoderFunc + func WithCodec(codec CodecName) EncoderFunc + func WithMetadata(meta map[string][]byte) EncoderFunc + type Header struct + Magic [4]byte + Meta map[string][]byte + Sync [16]byte + type NullCodec struct + func (*NullCodec) Decode(b []byte) ([]byte, error) + func (*NullCodec) Encode(b []byte) []byte + type SnappyCodec struct + func (*SnappyCodec) Decode(b []byte) ([]byte, error) + func (*SnappyCodec) Encode(b []byte) []byte
Go to main page