goavro

Nov 16, 2023

Changes in this version

+ func DecimalPlacesCount(value float64, scale int) int

+ func FloatToBigScaled(decimal float64, scale int) (*big.Int, error)

Nov 16, 2023

Changes in this version

+ const CompressionDeflateLabel

+ const CompressionNullLabel

+ const CompressionSnappyLabel

+ var MaxBlockCount = int64(math.MaxInt32)

+ var MaxBlockSize = int64(math.MaxInt32)

+ var RelaxedNameValidation bool

+ func FingerprintFromSOE(buf []byte) (uint64, []byte, error)

+ func Union(name string, datum interface{}) interface

+ type Codec struct

+ Rabin uint64

+ func NewCodec(schemaSpecification string) (*Codec, error)

+ func NewCodecForStandardJSON(schemaSpecification string) (*Codec, error)

+ func NewCodecForStandardJSONFull(schemaSpecification string) (*Codec, error)

+ func NewCodecForStandardJSONOneWay(schemaSpecification string) (*Codec, error)

+ func NewCodecFrom(schemaSpecification string, cb *codecBuilder) (*Codec, error)

+ func (c *Codec) BinaryFromNative(buf []byte, datum interface{}) ([]byte, error)

+ func (c *Codec) CanonicalSchema() string

+ func (c *Codec) NativeFromBinary(buf []byte) (interface{}, []byte, error)

+ func (c *Codec) NativeFromSingle(buf []byte) (interface{}, []byte, error)

+ func (c *Codec) NativeFromTextual(buf []byte) (interface{}, []byte, error)

+ func (c *Codec) Schema() string

+ func (c *Codec) SchemaCRC64Avro() int64

+ func (c *Codec) SingleFromNative(buf []byte, datum interface{}) ([]byte, error)

+ func (c *Codec) TextualFromNative(buf []byte, datum interface{}) ([]byte, error)

+ type ErrInvalidName struct

+ Message string

+ func (e ErrInvalidName) Error() string

+ type ErrNotSingleObjectEncoded string

+ func (e ErrNotSingleObjectEncoded) Error() string

+ type ErrWrongCodec uint64

+ func (e ErrWrongCodec) Error() string

+ type OCFConfig struct

+ Codec *Codec

+ CompressionName string

+ MetaData map[string][]byte

+ Schema string

+ W io.Writer

+ type OCFReader struct

+ func NewOCFReader(ior io.Reader) (*OCFReader, error)

+ func (ocfr *OCFReader) Codec() *Codec

+ func (ocfr *OCFReader) CompressionName() string

+ func (ocfr *OCFReader) Err() error

+ func (ocfr *OCFReader) MetaData() map[string][]byte

+ func (ocfr *OCFReader) Read() (interface{}, error)

+ func (ocfr *OCFReader) RemainingBlockItems() int64

+ func (ocfr *OCFReader) Scan() bool

+ func (ocfr *OCFReader) SkipThisBlockAndReset()

+ type OCFWriter struct

+ func NewOCFWriter(config OCFConfig) (*OCFWriter, error)

+ func (ocfw *OCFWriter) Append(data interface{}) error

+ func (ocfw *OCFWriter) Codec() *Codec

+ func (ocfw *OCFWriter) CompressionName() string