avro

Documentation

Overview

Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.

• SOURCE:
• primitives.avsc

Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.

• SOURCE:
• primitives.avsc

Index

• func NewPrimitiveTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type PrimitiveTestRecord
  • func DeserializePrimitiveTestRecord(r io.Reader) (t PrimitiveTestRecord, err error)
  • func DeserializePrimitiveTestRecordFromSchema(r io.Reader, schema string) (t PrimitiveTestRecord, err error)
  • func (_ *PrimitiveTestRecord) AppendArray() types.Field
  • func (_ *PrimitiveTestRecord) AppendMap(key string) types.Field
  • func (r *PrimitiveTestRecord) Clear(i int)
  • func (_ *PrimitiveTestRecord) Finalize()
  • func (r *PrimitiveTestRecord) Get(i int) types.Field
  • func (r PrimitiveTestRecord) Schema() string
  • func (r PrimitiveTestRecord) SchemaName() string
  • func (r PrimitiveTestRecord) Serialize(w io.Writer) error
  • func (_ *PrimitiveTestRecord) SetBoolean(v bool)
  • func (_ *PrimitiveTestRecord) SetBytes(v []byte)
  • func (r *PrimitiveTestRecord) SetDefault(i int)
  • func (_ *PrimitiveTestRecord) SetDouble(v float64)
  • func (_ *PrimitiveTestRecord) SetFloat(v float32)
  • func (_ *PrimitiveTestRecord) SetInt(v int32)
  • func (_ *PrimitiveTestRecord) SetLong(v int64)
  • func (_ *PrimitiveTestRecord) SetString(v string)
  • func (_ *PrimitiveTestRecord) SetUnionElem(v int64)
• type PrimitiveTestRecordReader
  • func NewPrimitiveTestRecordReader(r io.Reader) (*PrimitiveTestRecordReader, error)
  • func (r PrimitiveTestRecordReader) Read() (t PrimitiveTestRecord, err error)

Functions

func NewPrimitiveTestRecordWriter

func NewPrimitiveTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

Types

type PrimitiveTestRecord

type PrimitiveTestRecord struct {
	IntField int32

	LongField int64

	FloatField float32

	DoubleField float64

	StringField string

	BoolField bool

	BytesField []byte
}

func DeserializePrimitiveTestRecord

func DeserializePrimitiveTestRecord(r io.Reader) (t PrimitiveTestRecord, err error)

func DeserializePrimitiveTestRecordFromSchema

func DeserializePrimitiveTestRecordFromSchema(r io.Reader, schema string) (t PrimitiveTestRecord, err error)

func (*PrimitiveTestRecord) AppendArray

func (_ *PrimitiveTestRecord) AppendArray() types.Field

func (*PrimitiveTestRecord) AppendMap

func (_ *PrimitiveTestRecord) AppendMap(key string) types.Field

func (*PrimitiveTestRecord) Clear

func (r *PrimitiveTestRecord) Clear(i int)

func (*PrimitiveTestRecord) Finalize

func (_ *PrimitiveTestRecord) Finalize()

func (*PrimitiveTestRecord) Get

func (r *PrimitiveTestRecord) Get(i int) types.Field

func (PrimitiveTestRecord) Schema

func (r PrimitiveTestRecord) Schema() string

func (PrimitiveTestRecord) SchemaName

func (r PrimitiveTestRecord) SchemaName() string

func (PrimitiveTestRecord) Serialize

func (r PrimitiveTestRecord) Serialize(w io.Writer) error

func (*PrimitiveTestRecord) SetBoolean

func (_ *PrimitiveTestRecord) SetBoolean(v bool)

func (*PrimitiveTestRecord) SetBytes

func (_ *PrimitiveTestRecord) SetBytes(v []byte)

func (*PrimitiveTestRecord) SetDefault

func (r *PrimitiveTestRecord) SetDefault(i int)

func (*PrimitiveTestRecord) SetDouble

func (_ *PrimitiveTestRecord) SetDouble(v float64)

func (*PrimitiveTestRecord) SetFloat

func (_ *PrimitiveTestRecord) SetFloat(v float32)

func (*PrimitiveTestRecord) SetInt

func (_ *PrimitiveTestRecord) SetInt(v int32)

func (*PrimitiveTestRecord) SetLong

func (_ *PrimitiveTestRecord) SetLong(v int64)

func (*PrimitiveTestRecord) SetString

func (_ *PrimitiveTestRecord) SetString(v string)

func (*PrimitiveTestRecord) SetUnionElem

func (_ *PrimitiveTestRecord) SetUnionElem(v int64)

type PrimitiveTestRecordReader

type PrimitiveTestRecordReader struct {
	// contains filtered or unexported fields
}

container reader

func NewPrimitiveTestRecordReader

func NewPrimitiveTestRecordReader(r io.Reader) (*PrimitiveTestRecordReader, error)

func (PrimitiveTestRecordReader) Read

func (r PrimitiveTestRecordReader) Read() (t PrimitiveTestRecord, err error)