Versions in this module Expand all Collapse all v3 v3.0.1 Jan 15, 2017 v3.0.0 Jan 15, 2017 Changes in this version + const DemoSchemaSchema + type AvroContainerBlock struct + NumRecords int64 + RecordBytes []byte + Sync Sync + func DeserializeAvroContainerBlock(r io.Reader) (*AvroContainerBlock, error) + func (r AvroContainerBlock) Serialize(w io.Writer) error + type AvroContainerHeader struct + Magic Magic + Meta map[string][]byte + Sync Sync + func DeserializeAvroContainerHeader(r io.Reader) (*AvroContainerHeader, error) + func (r AvroContainerHeader) Serialize(w io.Writer) error + type ByteReader interface + ReadByte func() (byte, error) + type ByteWriter interface + Grow func(int) + WriteByte func(byte) error + type Codec string + const Deflate + const Null + const Snappy + type DemoSchema struct + BoolField bool + BytesField []byte + DoubleField float64 + IntField int32 + StringField string + func DeserializeDemoSchema(r io.Reader) (*DemoSchema, error) + func (r DemoSchema) Serialize(w io.Writer) error + type DemoSchemaContainerWriter struct + func NewDemoSchemaContainerWriter(writer io.Writer, codec Codec, recordsPerBlock int64) (*DemoSchemaContainerWriter, error) + func (avroWriter *DemoSchemaContainerWriter) Flush() error + func (avroWriter *DemoSchemaContainerWriter) WriteRecord(record DemoSchema) error + type FlushableResettableWriter interface + Flush func() error + Reset func(io.Writer) + type Magic [4]byte + type StringWriter interface + WriteString func(string) (int, error) + type Sync [16]byte Other modules containing this package gopkg.in/alanctgardner/gogen-avro.v2 gopkg.in/alanctgardner/gogen-avro.v4 gopkg.in/alanctgardner/gogen-avro.v5 gopkg.in/alanctgardner/gogen-avro.v6