avro

Aug 1, 2023

Changes in this version

+ var FileMagic = [4]byte

+ type Compression string

+ const CompressionDeflate

+ const CompressionNull

+ const CompressionSnappy

+ type FileWriter struct

+ func NewFileWriter(schema []byte, compression Compression) (*FileWriter, error)

+ func (f *FileWriter) AppendHeader(buf []byte) []byte

+ func (f *FileWriter) WriteBlock(w io.Writer, rowCount int, block []byte) error

+ func (f *FileWriter) WriteHeader(w io.Writer) error

Jan 3, 2023

Changes in this version

type Buffer

+ func (d *Buffer) ExtractResourceBank() *ResourceBank

type Schema

+ func SchemaFromString(in string) (Schema, error)

+ func (s Schema) Codec(out interface{}) (Codec, error)

Jun 22, 2022

Changes in this version

+ type IntCodec struct

+ func (IntCodec[T]) New(r *Buffer) unsafe.Pointer

+ func (IntCodec[T]) Read(r *Buffer, p unsafe.Pointer) error

+ func (IntCodec[T]) Skip(r *Buffer) error

Nov 23, 2021

Changes in this version

type Schema

+ func FileSchema(filename string) (Schema, error)

Nov 26, 2020

Changes in this version

type SchemaObject

+ LogicalType string

May 21, 2020

Changes in this version

type Buffer

+ func (d *Buffer) Alloc(rtyp reflect.Type) unsafe.Pointer

+ func (d *Buffer) NextAsString(l int) (string, error)

+ type PointerCodec struct

+ func (c *PointerCodec) New(r *Buffer) unsafe.Pointer

+ func (c *PointerCodec) Read(r *Buffer, p unsafe.Pointer) error

+ type ResourceBank struct

+ func (rb *ResourceBank) Alloc(rtyp reflect.Type) unsafe.Pointer

+ func (rb *ResourceBank) Close()

+ func (rb *ResourceBank) ToString(in []byte) string

May 1, 2020

Changes in this version

type Buffer

+ func (d *Buffer) Varint() (int64, error)

May 1, 2020

Changes in this version

+ type Buffer struct

+ func NewBuffer(data []byte) *Buffer

+ func (d *Buffer) Len() int

+ func (d *Buffer) Next(l int) ([]byte, error)

+ func (d *Buffer) ReadByte() (byte, error)

+ func (d *Buffer) Reset(data []byte)

Apr 30, 2020

Changes in this version

+ func ReadFile(r Reader, out interface{}, cb func(val unsafe.Pointer) error) error

+ func Register(typ reflect.Type, f CodecBuildFunc)

+ type BoolCodec struct

+ func (BoolCodec) New() unsafe.Pointer

+ func (BoolCodec) Read(r Reader, p unsafe.Pointer) error

+ func (BoolCodec) Skip(r Reader) error

+ type BytesCodec struct

+ func (BytesCodec) New() unsafe.Pointer

+ func (BytesCodec) Read(r Reader, ptr unsafe.Pointer) error

+ func (BytesCodec) Skip(r Reader) error

+ type Codec interface

+ New func() unsafe.Pointer

+ Read func(r Reader, p unsafe.Pointer) error

+ Skip func(r Reader) error

+ type CodecBuildFunc func(schema Schema, typ reflect.Type) (Codec, error)

+ type DoubleCodec struct

+ func (DoubleCodec) New() unsafe.Pointer

+ func (DoubleCodec) Read(r Reader, p unsafe.Pointer) error

+ func (DoubleCodec) Skip(r Reader) error

+ type FileHeader struct

+ Magic [4]byte

+ Meta map[string][]byte

+ Sync [16]byte

+ type Float32DoubleCodec struct

+ func (Float32DoubleCodec) New() unsafe.Pointer

+ func (c Float32DoubleCodec) Read(r Reader, p unsafe.Pointer) error

+ type FloatCodec struct

+ func (FloatCodec) New() unsafe.Pointer

+ func (FloatCodec) Read(r Reader, p unsafe.Pointer) error

+ func (FloatCodec) Skip(r Reader) error

+ type Int16Codec struct

+ func (Int16Codec) New() unsafe.Pointer

+ func (Int16Codec) Read(r Reader, p unsafe.Pointer) error

+ func (Int16Codec) Skip(r Reader) error

+ type Int32Codec struct

+ func (Int32Codec) New() unsafe.Pointer

+ func (Int32Codec) Read(r Reader, p unsafe.Pointer) error

+ func (Int32Codec) Skip(r Reader) error

+ type Int64Codec struct

+ func (Int64Codec) New() unsafe.Pointer

+ func (Int64Codec) Read(r Reader, p unsafe.Pointer) error

+ func (Int64Codec) Skip(r Reader) error

+ type MapCodec struct

+ func (m MapCodec) New() unsafe.Pointer

+ func (m MapCodec) Read(r Reader, p unsafe.Pointer) error

+ func (m MapCodec) Skip(r Reader) error

+ type Reader interface

+ type Schema struct

+ Object *SchemaObject

+ Type string

+ Union []Schema

+ type SchemaObject struct

+ Fields []SchemaRecordField

+ Items Schema

+ Name string

+ Namespace string

+ Size int

+ Symbols []string

+ Type string

+ Values Schema

+ type SchemaRecordField struct

+ Name string

+ Type Schema

+ type StringCodec struct

+ func (StringCodec) New() unsafe.Pointer

+ func (StringCodec) Read(r Reader, ptr unsafe.Pointer) error

+ func (StringCodec) Skip(r Reader) error