goavro

Jun 10, 2017

Changes in this version

+ type OCFConfig struct

+ Codec *Codec

+ CompressionName string

+ Schema string

+ W io.Writer

type OCFReader

+ func (ocfr *OCFReader) RemainingBlockItems() int64

+ func (ocfr *OCFReader) SkipThisBlockAndReset()

type OCFWriter

+ func (ocfw *OCFWriter) Codec() *Codec

+ func (ocfw *OCFWriter) CompressionName() string

Jun 5, 2017

Changes in this version

type OCFReader

+ func (ocfr *OCFReader) RemainingItems() int64

May 31, 2017

Changes in this version

type Codec

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

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

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

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

May 16, 2017

Changes in this version

type Codec

+ func (c Codec) Schema() string

May 10, 2017

Changes in this version

type OCFReader

+ func (ocfr *OCFReader) CompressionID() Compression

+ func (ocfr *OCFReader) CompressionName() string

May 10, 2017

Changes in this version

+ var MaxBlockCount = int64(math.MaxInt32)

+ var MaxBlockSize = int64(math.MaxInt32)

type Codec

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

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

type OCFReader

+ func (ocfr *OCFReader) Codec() *Codec

+ type TextCoder interface

+ type TextDecoder interface

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

+ type TextEncoder interface

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

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