Versions in this module Expand all Collapse all v3 v3.0.0 Oct 9, 2020 Changes in this version + const CompressionDeflateLabel + const CompressionNullLabel + const CompressionSnappyLabel + var MaxBlockCount = int64(math.MaxInt32) + var MaxBlockSize = int64(math.MaxInt32) + var RelaxedNameValidation bool + func Union(name string, datum interface{}) interface + type Codec struct + 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) NativeFromTextual(buf []byte) (interface{}, []byte, error) + func (c *Codec) Schema() string + func (c *Codec) SchemaCRC64Avro() int64 + func (c *Codec) TextualFromNative(buf []byte, datum interface{}) ([]byte, error) + type ErrInvalidName struct + Message string + func (e ErrInvalidName) 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, codec *Codec) (*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/tokopedia/goavro