avro

Jan 24, 2025

Changes in this version

type Codec

+ func BuildMapCodec(schema Schema, typ reflect.Type, omit bool) (Codec, error)

type Schema

+ func (s *Schema) Marshal() ([]byte, error)

Dec 17, 2024

Changes in this version

type ReadBuf

+ func NewReadBuf(data []byte) *ReadBuf

Dec 16, 2024

Changes in this version

+ func RegisterSchema(typ reflect.Type, s Schema)

type BoolCodec

+ func (rc BoolCodec) Omit(p unsafe.Pointer) bool

+ func (rc BoolCodec) Write(w *WriteBuf, p unsafe.Pointer)

type BytesCodec

+ func (rc BytesCodec) Omit(p unsafe.Pointer) bool

+ func (rc BytesCodec) Write(w *WriteBuf, p unsafe.Pointer)

type Codec

+ Omit func(p unsafe.Pointer) bool

+ Write func(w *WriteBuf, p unsafe.Pointer)

+ type Encoder struct

+ func NewEncoderFor[T any](w io.Writer, compression Compression, approxBlockSize int) (*Encoder[T], error)

+ func (e *Encoder[T]) Encode(v T) error

+ func (e *Encoder[T]) Flush() error

type Float32DoubleCodec

+ func (rc Float32DoubleCodec) Omit(p unsafe.Pointer) bool

+ func (rc Float32DoubleCodec) Write(w *WriteBuf, p unsafe.Pointer)

type IntCodec

+ func (rc IntCodec[T]) Omit(p unsafe.Pointer) bool

+ func (rc IntCodec[T]) Write(w *WriteBuf, p unsafe.Pointer)

type MapCodec

+ func (m *MapCodec) Omit(p unsafe.Pointer) bool

+ func (m *MapCodec) Write(w *WriteBuf, p unsafe.Pointer)

type PointerCodec

+ func (c *PointerCodec) Omit(p unsafe.Pointer) bool

+ func (c *PointerCodec) Write(w *WriteBuf, p unsafe.Pointer)

+ type ReadBuf struct

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

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

+ func (d *ReadBuf) Len() int

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

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

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

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

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

type Schema

+ func SchemaForType(item any) (Schema, error)

type StringCodec

+ func (StringCodec) Write(w *WriteBuf, p unsafe.Pointer)

+ func (sc StringCodec) Omit(p unsafe.Pointer) bool

+ type WriteBuf struct

+ func NewWriteBuf(buf []byte) *WriteBuf

+ func (w *WriteBuf) Byte(val byte)

+ func (w *WriteBuf) Bytes() []byte

+ func (w *WriteBuf) Len() int

+ func (w *WriteBuf) Reset()

+ func (w *WriteBuf) Varint(v int64)

+ func (w *WriteBuf) Write(val []byte)

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