Versions in this module Expand all Collapse all v2 v2.11.0 May 18, 2020 Changes in this version + func FromUnixMilli(ms int64) time.Time v2.10.0 May 15, 2020 Changes in this version + const CompressionDeflateLabel + const CompressionNullLabel + const CompressionSnappyLabel + var AllowUnwrappedUnionsForOptionalFields = false + 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 (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 Other modules containing this package github.com/90poe/goavro
Go to main page