avro

Documentation

Overview

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

• SOURCE:
• example.avsc

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

• SOURCE:
• example.avsc

Index

• Constants
• func NewDemoSchemaWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type DemoSchema
  • func DeserializeDemoSchema(r io.Reader) (*DemoSchema, error)
  • func DeserializeDemoSchemaFromSchema(r io.Reader, schema string) (*DemoSchema, error)
  • func NewDemoSchema() *DemoSchema
  • func (_ *DemoSchema) AppendArray() types.Field
  • func (_ *DemoSchema) AppendMap(key string) types.Field
  • func (_ *DemoSchema) AvroCRC64Fingerprint() []byte
  • func (_ *DemoSchema) Finalize()
  • func (r *DemoSchema) Get(i int) types.Field
  • func (r *DemoSchema) Schema() string
  • func (r *DemoSchema) SchemaName() string
  • func (r *DemoSchema) Serialize(w io.Writer) error
  • func (_ *DemoSchema) SetBoolean(v bool)
  • func (_ *DemoSchema) SetBytes(v []byte)
  • func (r *DemoSchema) SetDefault(i int)
  • func (_ *DemoSchema) SetDouble(v float64)
  • func (_ *DemoSchema) SetFloat(v float32)
  • func (_ *DemoSchema) SetInt(v int32)
  • func (_ *DemoSchema) SetLong(v int64)
  • func (_ *DemoSchema) SetString(v string)
  • func (_ *DemoSchema) SetUnionElem(v int64)
• type DemoSchemaReader
  • func NewDemoSchemaReader(r io.Reader) (*DemoSchemaReader, error)
  • func (r DemoSchemaReader) Read() (*DemoSchema, error)

Constants

const DemoSchemaAvroCRC64Fingerprint = "\xc4V\xa9\x04ʛf\xad"

Functions

func NewDemoSchemaWriter

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

Types

type DemoSchema

type DemoSchema struct {
	IntField int32

	DoubleField float64

	StringField string

	BoolField bool

	BytesField []byte
}

func DeserializeDemoSchema

func DeserializeDemoSchema(r io.Reader) (*DemoSchema, error)

func DeserializeDemoSchemaFromSchema

func DeserializeDemoSchemaFromSchema(r io.Reader, schema string) (*DemoSchema, error)

func NewDemoSchema

func NewDemoSchema() *DemoSchema

func (*DemoSchema) AppendArray

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

func (*DemoSchema) AppendMap

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

func (*DemoSchema) AvroCRC64Fingerprint

func (_ *DemoSchema) AvroCRC64Fingerprint() []byte

func (*DemoSchema) Finalize

func (_ *DemoSchema) Finalize()

func (*DemoSchema) Get

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

func (*DemoSchema) Schema

func (r *DemoSchema) Schema() string

func (*DemoSchema) SchemaName

func (r *DemoSchema) SchemaName() string

func (*DemoSchema) Serialize

func (r *DemoSchema) Serialize(w io.Writer) error

func (*DemoSchema) SetBoolean

func (_ *DemoSchema) SetBoolean(v bool)

func (*DemoSchema) SetBytes

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

func (*DemoSchema) SetDefault

func (r *DemoSchema) SetDefault(i int)

func (*DemoSchema) SetDouble

func (_ *DemoSchema) SetDouble(v float64)

func (*DemoSchema) SetFloat

func (_ *DemoSchema) SetFloat(v float32)

func (*DemoSchema) SetInt

func (_ *DemoSchema) SetInt(v int32)

func (*DemoSchema) SetLong

func (_ *DemoSchema) SetLong(v int64)

func (*DemoSchema) SetString

func (_ *DemoSchema) SetString(v string)

func (*DemoSchema) SetUnionElem

func (_ *DemoSchema) SetUnionElem(v int64)

type DemoSchemaReader

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

container reader

func NewDemoSchemaReader

func NewDemoSchemaReader(r io.Reader) (*DemoSchemaReader, error)

func (DemoSchemaReader) Read

func (r DemoSchemaReader) Read() (*DemoSchema, error)