goavro

May 2, 2017

Changes in this version

+ const CompressionDeflateLabel

+ const CompressionNullLabel

+ const CompressionSnappyLabel

+ type Compression uint8

+ const CompressionDeflate

+ const CompressionNull

+ const CompressionSnappy

+ type OCFReader struct

+ func NewOCFReader(ior io.Reader) (*OCFReader, error)

+ func (ocfr *OCFReader) Err() error

+ func (ocfr *OCFReader) Read() (interface{}, error)

+ func (ocfr *OCFReader) Scan() bool

+ func (ocfr *OCFReader) Schema() string

+ type OCFWriter struct

+ func NewOCFWriter(config OCFWriterConfig) (*OCFWriter, error)

+ func (ocf *OCFWriter) Append(data []interface{}) error

+ type OCFWriterConfig struct

+ Compression Compression

+ Schema string

+ W io.Writer

Apr 26, 2017

Changes in this version

+ type Codec struct

+ func (c Codec) BinaryDecode(buf []byte) (interface{}, []byte, error)

+ func (c Codec) BinaryEncode(buf []byte, datum interface{}) ([]byte, error)

Apr 23, 2017

Changes in this version

+ func Union(name string, datum interface{}) interface

Apr 22, 2017

Changes in this version

+ type BinaryCoder interface

+ func NewCodec(schemaSpecification string) (BinaryCoder, error)

+ type BinaryDecoder interface

+ BinaryDecode func([]byte) (interface{}, []byte, error)

+ type BinaryEncoder interface

+ BinaryEncode func([]byte, interface{}) ([]byte, error)

+ type ErrInvalidName struct

+ Message string

+ func (e ErrInvalidName) Error() string

+ type Name struct

+ FullName string

+ Namespace string

+ func NewName(name, namespace, enclosingNamespace string) (*Name, error)

+ func (n Name) Equal(n2 Name) bool

+ func (n Name) String() string