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

v1

v1.0.5

Jun 24, 2017

v1.0.4

Jun 1, 2017

v1.0.3

Apr 5, 2017

v1.0.2

Apr 5, 2017

v1.0.1

Jan 30, 2017

v1.0.0

Aug 17, 2016

Changes in this version

+ const CompressionDeflate

+ const CompressionNull

+ const CompressionSnappy

+ const DefaultWriterBlockSize

+ var MaxDecodeSize = int64(math.MaxInt32)

+ func IsCompressionCodecSupported(someCodec string) bool

+ type ByteWriter interface

+ Grow func(int)

+ WriteByte func(byte) error

+ type Codec interface

+ NewWriter func(...WriterSetter) (*Writer, error)

+ Schema func() string

+ func NewCodec(someJSONSchema string, setters ...CodecSetter) (Codec, error)

+ type CodecSetter func(Codec) error

+ type Datum struct

+ Err error

+ Value interface{}

+ type Decoder interface

+ Decode func(io.Reader) (interface{}, error)

+ type Encoder interface

+ Encode func(io.Writer, interface{}) error

+ type Enum struct

+ Name string

+ Value string

+ type ErrCodecBuild struct

+ Err error

+ Message string

+ func (e ErrCodecBuild) Error() string

+ type ErrDecoder struct

+ Err error

+ Message string

+ func (e ErrDecoder) Error() string

+ type ErrEncoder struct

+ Err error

+ Message string

+ func (e ErrEncoder) Error() string

+ type ErrInvalidName struct

+ Message string

+ func (e ErrInvalidName) Error() string

+ type ErrNoSuchField struct

+ func (e ErrNoSuchField) Error() string

+ type ErrNotRecord struct

+ func (e ErrNotRecord) Error() string

+ type ErrReader struct

+ Err error

+ Message string

+ func (e ErrReader) Error() string

+ type ErrReaderBlockCount struct

+ Err error

+ func (e *ErrReaderBlockCount) Error() string

+ type ErrReaderInit struct

+ Err error

+ Message string

+ func (e ErrReaderInit) Error() string

+ type ErrSchemaParse struct

+ Err error

+ Message string

+ func (e ErrSchemaParse) Error() string

+ type ErrWriterInit struct

+ Err error

+ Message string

+ func (e *ErrWriterInit) Error() string

+ type Fixed struct

+ Name string

+ Value []byte

+ type Reader struct

+ CompressionCodec string

+ DataSchema string

+ Sync []byte

+ func NewReader(setters ...ReaderSetter) (*Reader, error)

+ func (fr *Reader) Close() error

+ func (fr *Reader) Read() (interface{}, error)

+ func (fr *Reader) Scan() bool

+ type ReaderSetter func(*Reader) error

+ func BufferFromReader(r io.Reader) ReaderSetter

+ func FromReader(r io.Reader) ReaderSetter

+ type Record struct

+ Fields []*recordField

+ Name string

+ func NewRecord(setters ...RecordSetter) (*Record, error)

+ func (r Record) Get(fieldName string) (interface{}, error)

+ func (r Record) GetFieldSchema(fieldName string) (interface{}, error)

+ func (r Record) GetQualified(qualifiedName string) (interface{}, error)

+ func (r Record) Set(fieldName string, value interface{}) error

+ func (r Record) SetQualified(qualifiedName string, value interface{}) error

+ func (r Record) String() string

+ type RecordCache struct

+ func NewRecordCache(record *Record, delim byte) (*RecordCache, error)

+ func (rc *RecordCache) Get(name string) (interface{}, error)

+ type RecordSetter func(*Record) error

+ func RecordEnclosingNamespace(someNamespace string) RecordSetter

+ func RecordPedantic() RecordSetter

+ func RecordSchema(recordSchemaJSON string) RecordSetter

+ type StringWriter interface

+ WriteString func(string) (int, error)

+ type Writer struct

+ CompressionCodec string

+ Sync []byte

+ func NewWriter(setters ...WriterSetter) (*Writer, error)

+ func (fw *Writer) Close() error

+ func (fw *Writer) Write(datum interface{})

+ type WriterSetter func(*Writer) error

+ func BlockSize(blockSize int64) WriterSetter

+ func BlockTick(blockTick time.Duration) WriterSetter

+ func BufferToWriter(w io.Writer) WriterSetter

+ func Compression(someCompressionCodec string) WriterSetter

+ func Sync(someSync []byte) WriterSetter

+ func ToWriter(w io.Writer) WriterSetter

+ func UseCodec(codec Codec) WriterSetter

+ func WriterSchema(someSchema string) WriterSetter

JackTT - Gopher 🇻🇳