avro

Apr 13, 2026

Changes in this version

+ func RatFromBytes(b []byte, scale int) *big.Rat

Mar 30, 2026

Changes in this version

+ var ErrSkipCustomType = errors.New("avro: skip custom type")

+ type CustomType struct

+ AvroType string

+ Decode func(v any, schema *SchemaNode) (any, error)

+ Encode func(v any, schema *SchemaNode) (any, error)

+ GoType reflect.Type

+ LogicalType string

+ Schema *SchemaNode

+ func NewCustomType[G, A any](logicalType string, encode func(G, *SchemaNode) (A, error), ...) CustomType

type Duration

+ func DurationFromBytes(b []byte) Duration

+ func (d Duration) Bytes() [12]byte

+ func (d Duration) String() string

+ type Opt interface

+ func LinkedinFloats() Opt

+ func TagLogicalTypes() Opt

+ func TaggedUnions() Opt

type Schema

+ func (s *Schema) AppendEncodeJSON(dst []byte, v any, opts ...Opt) ([]byte, error)

type SchemaField

+ HasDefault bool

+ Order string

type SchemaNode

+ Aliases []string

+ EnumDefault string

+ HasEnumDefault bool

type SchemaOpt

+ func WithCustomType(ct CustomType) SchemaOpt

Mar 28, 2026

retracted

Changes in this version

type Schema

+ func (s *Schema) DecodeJSON(src []byte, v any) error

+ func (s *Schema) EncodeJSON(v any) ([]byte, error)

+ func (s *Schema) Root() SchemaNode

+ type SchemaField struct

+ Aliases []string

+ Default any

+ Doc string

+ Name string

+ Props map[string]string

+ Type SchemaNode

+ type SchemaNode struct

+ Branches []SchemaNode

+ Doc string

+ Fields []SchemaField

+ Items *SchemaNode

+ LogicalType string

+ Name string

+ Namespace string

+ Precision int

+ Props map[string]string

+ Scale int

+ Size int

+ Symbols []string

+ Type string

+ Values *SchemaNode

+ func (n *SchemaNode) Schema() (*Schema, error)

Mar 28, 2026

retracted

Changes in this version

type Schema

+ func MustSchemaFor[T any](opts ...SchemaOpt) *Schema

+ func SchemaFor[T any](opts ...SchemaOpt) (*Schema, error)

+ type SchemaOpt func(*schemaOpts)

+ func WithName(name string) SchemaOpt

+ func WithNamespace(ns string) SchemaOpt

Mar 11, 2026

Changes in this version

+ func CheckCompatibility(writer, reader *Schema) error

+ func NewRabin() hash.Hash64

+ func SingleObjectFingerprint(data []byte) (fp [8]byte, rest []byte, err error)

+ type CompatibilityError struct

+ Detail string

+ Path string

+ ReaderType string

+ WriterType string

+ func (e *CompatibilityError) Error() string

+ type Duration struct

+ Days uint32

+ Milliseconds uint32

+ Months uint32

+ type ParseOpt interface

+ func WithLaxNames(fn func(string) error) ParseOpt

+ type Schema struct

+ func MustParse(schema string, opts ...ParseOpt) *Schema

+ func Parse(schema string, opts ...ParseOpt) (*Schema, error)

+ func Resolve(writer, reader *Schema) (*Schema, error)

+ func (s *Schema) AppendEncode(dst []byte, v any) ([]byte, error)

+ func (s *Schema) AppendSingleObject(dst []byte, v any) ([]byte, error)

+ func (s *Schema) Canonical() []byte

+ func (s *Schema) Decode(src []byte, v any) ([]byte, error)

+ func (s *Schema) DecodeSingleObject(data []byte, v any) ([]byte, error)

+ func (s *Schema) Encode(v any) ([]byte, error)

+ func (s *Schema) Fingerprint(h hash.Hash) []byte

+ func (s *Schema) String() string

+ type SchemaCache struct

+ func NewSchemaCache() *SchemaCache

+ func (c *SchemaCache) Parse(schema string, opts ...ParseOpt) (*Schema, error)

+ type SemanticError struct

+ AvroType string

+ Err error

+ Field string

+ GoType reflect.Type

+ func (e *SemanticError) Error() string

+ func (e *SemanticError) Unwrap() error

+ type ShortBufferError struct

+ Have int

+ Need int

+ Type string

+ func (e *ShortBufferError) Error() string