Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

goavro

package module

Go to main page

Versions in this module

v2

v2.11.6

Jul 15, 2022

v2.11.5

Jul 12, 2022

v2.11.4

Jul 12, 2022

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)

+ type Codec struct

+ Rabin uint64

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

+ func NewCodecForStandardJSON(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

Other modules containing this package

github.com/cpoole/goavro