avrox

package module

Go to main page

Versions in this module

v0

v0.7.2

Mar 20, 2024

v0.7.1

Mar 20, 2024

v0.7.0

Mar 20, 2024

v0.6.0

Mar 14, 2024

v0.5.0

Mar 14, 2024

v0.4.2

Mar 4, 2024

v0.4.1

Feb 21, 2024

Changes in this version

+ var ErrNoBasicDecimal = errors.New("no basic decimal")

v0.4.0

Feb 21, 2024

v0.3.3

Feb 20, 2024

v0.3.2

Feb 20, 2024

v0.3.1

Feb 20, 2024

v0.3.0

Feb 20, 2024

Changes in this version

+ var BasicRawDateAVSC string

+ var ErrNoBasicRawDate = errors.New("no basic rawdate")

+ type BasicRawDate struct

+ Magic [MagicLen]byte

+ Value rawdate.RawDate

+ func (BasicRawDate) NamespaceID() NamespaceID

+ func (BasicRawDate) Schema() string

+ func (BasicRawDate) SchemaID() SchemaID

type SchemaID

+ const BasicRawDateSchemaID

v0.2.1

Feb 12, 2024

v0.2.0

Nov 21, 2023

Changes in this version

+ var ErrNoData = errors.New("no data")

v0.1.0

Oct 13, 2023

Changes in this version

+ func CompressData(data []byte, cID CompressionID) ([]byte, error)

+ func DecompressData(data []byte, cID CompressionID) ([]byte, error)

v0.0.3

Sep 18, 2023

v0.0.2

Sep 12, 2023

v0.0.1

Sep 12, 2023

Changes in this version

+ const CompFlate

+ const CompGZip

+ const CompMax

+ const CompNone

+ const CompSnappy

+ const MagicFieldName

+ const MagicLen

+ const NamespaceBasic

+ const NamespaceMax

+ const NamespacePrivate

+ const NamespaceReserved1

+ const NamespaceReserved2

+ const NamespaceReserved3

+ const SchemaMax

+ const SchemaUndefined

+ var BasicByteSliceAVSC string

+ var BasicDecimalAVSC string

+ var BasicIntAVSC string

+ var BasicMapStringAnyAVSC string

+ var BasicStringAVSC string

+ var BasicTimeAVSC string

+ var ErrCompressionIDOutOfRange = errors.New("compression must be between 0 and 7")

+ var ErrCompressionUnsupported = errors.New("compression type is unsupported")

+ var ErrDataFormatNotDetected = errors.New("message format was not detected")

+ var ErrDecompress = errors.New("can not decompress")

+ var ErrLengthInvalid = errors.New("data length should be exactly 4 bytes")

+ var ErrMarkerInvalid = fmt.Errorf("data should start with magic marker (0x%02x)", Marker)

+ var ErrMarshallAnyWithoutPtr = errors.New("no ptr src for MarshalAny")

+ var ErrMarshallingFailed = errors.New("marshalling failed")

+ var ErrMissingMagicField = errors.New("missing magic field in struct")

+ var ErrNamespaceIDOutOfRange = errors.New("namespace must be between 0 and 31")

+ var ErrNoBasicByteSlice = errors.New("no basic byte slice")

+ var ErrNoBasicInt = errors.New("no basic int")

+ var ErrNoBasicMapStringAny = errors.New("no basic map string any")

+ var ErrNoBasicNamespace = errors.New("no basic namespace")

+ var ErrNoBasicSchema = errors.New("no basic schema")

+ var ErrNoBasicString = errors.New("no basic string")

+ var ErrNoBasicTime = errors.New("no basic time")

+ var ErrNoPointerDestination = errors.New("not a pointer destination")

+ var ErrNotAvroX = errors.New("data is not avrox")

+ var ErrParityCheckFailed = errors.New("parity check failed")

+ var ErrSchemaIDOutOfRange = errors.New("schema must be between 0 and 8191")

+ var ErrSchemaInvalid = errors.New("schema is invalid")

+ var ErrSchemaNil = errors.New("schema is nil")

+ var ErrSchemerNotFound = errors.New("schema from schemer is not in the given slice")

+ var ErrWrongNamespace = errors.New("namespace from schemer does not fit the magic entry")

+ var ErrWrongSchema = errors.New("schema from schemer does not fit the magic entry")

+ var Marker byte = 0x93

+ func AvroDate(t time.Time) time.Time

+ func AvroTime(t time.Time) time.Time

+ func DecodeMagic(data []byte) (NamespaceID, SchemaID, CompressionID, error)

+ func IsMagic(data []byte) bool

+ func JoinedSchemas(schemers ...Schemer) string

+ func Marshal(src Schemer, cID CompressionID, schema avro.Schema) ([]byte, error)

+ func MarshalAny(src any, schema avro.Schema, nID NamespaceID, sID SchemaID, cID CompressionID) ([]byte, error)

+ func MarshalBasic(src any, cID CompressionID) ([]byte, error)

+ func Unmarshal(data []byte, dst Schemer, schema avro.Schema) error

+ func UnmarshalAny(data []byte, schema avro.Schema, dst *T) (NamespaceID, SchemaID, error)

+ func UnmarshalBasic(src []byte) (any, error)

+ func UnmarshalInt(data []byte) (int, error)

+ func UnmarshalSchemer(src []byte, schemers ...Schemer) (any, error)

+ func UnmarshalString(data []byte) (string, error)

+ func UnpackSchemVer(schemaVerID SchemaID) (int, int)

+ type BasicByteSlice struct

+ Magic [MagicLen]byte

+ Value []byte

+ func (_ *BasicByteSlice) NamespaceID() NamespaceID

+ func (_ *BasicByteSlice) Schema() string

+ func (_ *BasicByteSlice) SchemaID() SchemaID

+ type BasicDecimal struct

+ Magic [MagicLen]byte

+ Value *big.Rat

+ func (_ *BasicDecimal) NamespaceID() NamespaceID

+ func (_ *BasicDecimal) Schema() string

+ func (_ *BasicDecimal) SchemaID() SchemaID

+ type BasicInt struct

+ Magic [MagicLen]byte

+ Value int

+ func (_ *BasicInt) NamespaceID() NamespaceID

+ func (_ *BasicInt) Schema() string

+ func (_ *BasicInt) SchemaID() SchemaID

+ type BasicMapStringAny struct

+ Magic [MagicLen]byte

+ Value map[string]any

+ func (_ *BasicMapStringAny) NamespaceID() NamespaceID

+ func (_ *BasicMapStringAny) Schema() string

+ func (_ *BasicMapStringAny) SchemaID() SchemaID

+ type BasicString struct

+ Magic [MagicLen]byte

+ Value string

+ func (_ *BasicString) NamespaceID() NamespaceID

+ func (_ *BasicString) Schema() string

+ func (_ *BasicString) SchemaID() SchemaID

+ type BasicTime struct

+ Magic [MagicLen]byte

+ Value time.Time

+ func (_ *BasicTime) NamespaceID() NamespaceID

+ func (_ *BasicTime) Schema() string

+ func (_ *BasicTime) SchemaID() SchemaID

+ type CompressionID int

+ type Magic [MagicLen]byte

+ func EncodeMagic(namespace NamespaceID, schema SchemaID, compression CompressionID) (Magic, error)

+ func EncodePrivateMagic(compression CompressionID) (Magic, error)

+ func MustEncodeBasicMagic(schemaID SchemaID, compression CompressionID) Magic

+ func MustEncodePrivateMagic(compression CompressionID) Magic

+ type NamespaceID int

+ type SchemaID int

+ const BasicByteSliceSchemaID

+ const BasicDecimalSchemaID

+ const BasicIntSchemaID

+ const BasicMapStringAnySchemaID

+ const BasicStringSchemaID

+ const BasicTimeSchemaID

+ func PackSchemVer(schemaID SchemaID, version int) SchemaID

+ type Schemer interface

+ NamespaceID func() NamespaceID

+ Schema func() string

+ SchemaID func() SchemaID

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL