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.8.6

Jan 16, 2020

Changes in this version

+ func BoolNativePtrFromBinary(buf []byte) (*bool, []byte, error)

+ func DoubleNativePtrFromBinary(buf []byte) (*float64, []byte, error)

+ func FloatNativePtrFromBinary(buf []byte) (*float32, []byte, error)

+ func IntEnumNativeFromBinary(buf []byte) (int, []byte, error)

+ func IntEnumPtrNativeFromBinary(buf []byte) (*int, []byte, error)

+ func IntNativePtrFromBinary(buf []byte) (*int32, []byte, error)

+ func LongNativePtrFromBinary(buf []byte) (*int64, []byte, error)

+ func NativePtrFromBinaryDate(buf []byte) (*time.Time, []byte, error)

+ func StringNativePtrFromBinary(buf []byte) (*string, []byte, error)

type CodecGenerator

+ func NewEnumCodecGenerator(enumName *name, symbols []string) *CodecGenerator

v2.8.5

Sep 13, 2019

Changes in this version

+ const CompressionDeflateLabel

+ const CompressionNullLabel

+ const CompressionSnappyLabel

+ var MaxBlockCount = int64(math.MaxInt32)

+ var MaxBlockSize = int64(math.MaxInt32)

+ var RelaxedNameValidation bool

+ func BoolNativeFromBinary(buf []byte) (bool, []byte, error)

+ func DecodeBlockCount(buf []byte) (int64, []byte, error)

+ func DoubleNativeFromBinary(buf []byte) (float64, []byte, error)

+ func FloatNativeFromBinary(buf []byte) (float32, []byte, error)

+ func Generate(packageName string, inputFiles []string, outputDir string, verbose bool) error

+ func IntNativeFromBinary(buf []byte) (int32, []byte, error)

+ func LongNativeFromBinary(buf []byte) (int64, []byte, error)

+ func NativeFromBinaryDate(buf []byte) (time.Time, []byte, error)

+ func NativeFromBinaryDecimalBytes(buf []byte, precision int, scale int) (*big.Rat, []byte, error)

+ func StringNativeFromBinary(buf []byte) (string, []byte, error)

+ 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 CodecGenerator struct

+ func NewArrayCodecGenerator(realCodec *Codec) *CodecGenerator

+ func NewBoolCodecGenerator() *CodecGenerator

+ func NewDecimalBytesCodecGenerator(precision, scale int) *CodecGenerator

+ func NewDoubleCodecGenerator() *CodecGenerator

+ func NewFloatCodecGenerator() *CodecGenerator

+ func NewIntCodecGenerator() *CodecGenerator

+ func NewIntDateCodecGenerator() *CodecGenerator

+ func NewLongCodecGenerator() *CodecGenerator

+ func NewRecordCodecGenerator(recordTypeName *name, codecFromIndex []*Codec, nameFromIndex []string) *CodecGenerator

+ func NewStringCodecGenerator() *CodecGenerator

+ func NewUnionCodecGenerator(codecFromIndex []*Codec) (*CodecGenerator, 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) (*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/peak6/goavro