avro

Documentation

Overview

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

• SOURCE:
• schema.avsc

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

• SOURCE:
• schema.avsc

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

• SOURCE:
• schema.avsc

Index

• Constants
• func NewFixedDefaultTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type FixedDefaultTestRecord
  • func DeserializeFixedDefaultTestRecord(r io.Reader) (FixedDefaultTestRecord, error)
  • func DeserializeFixedDefaultTestRecordFromSchema(r io.Reader, schema string) (FixedDefaultTestRecord, error)
  • func NewFixedDefaultTestRecord() FixedDefaultTestRecord
  • func (_ FixedDefaultTestRecord) AppendArray() types.Field
  • func (_ FixedDefaultTestRecord) AppendMap(key string) types.Field
  • func (_ FixedDefaultTestRecord) AvroCRC64Fingerprint() []byte
  • func (_ FixedDefaultTestRecord) Finalize()
  • func (r *FixedDefaultTestRecord) Get(i int) types.Field
  • func (r FixedDefaultTestRecord) MarshalJSON() ([]byte, error)
  • func (r *FixedDefaultTestRecord) NullField(i int)
  • func (r FixedDefaultTestRecord) Schema() string
  • func (r FixedDefaultTestRecord) SchemaName() string
  • func (r FixedDefaultTestRecord) Serialize(w io.Writer) error
  • func (_ FixedDefaultTestRecord) SetBoolean(v bool)
  • func (_ FixedDefaultTestRecord) SetBytes(v []byte)
  • func (r *FixedDefaultTestRecord) SetDefault(i int)
  • func (_ FixedDefaultTestRecord) SetDouble(v float64)
  • func (_ FixedDefaultTestRecord) SetFloat(v float32)
  • func (_ FixedDefaultTestRecord) SetInt(v int32)
  • func (_ FixedDefaultTestRecord) SetLong(v int64)
  • func (_ FixedDefaultTestRecord) SetString(v string)
  • func (_ FixedDefaultTestRecord) SetUnionElem(v int64)
  • func (r *FixedDefaultTestRecord) UnmarshalJSON(data []byte) error
• type FixedDefaultTestRecordReader
  • func NewFixedDefaultTestRecordReader(r io.Reader) (*FixedDefaultTestRecordReader, error)
  • func (r FixedDefaultTestRecordReader) Read() (FixedDefaultTestRecord, error)
• type TestFixedDefaultType
  • func (b TestFixedDefaultType) MarshalJSON() ([]byte, error)
  • func (b *TestFixedDefaultType) UnmarshalJSON(data []byte) error
• type TestFixedDefaultTypeWrapper
  • func (_ *TestFixedDefaultTypeWrapper) AppendArray() types.Field
  • func (_ *TestFixedDefaultTypeWrapper) AppendMap(key string) types.Field
  • func (_ *TestFixedDefaultTypeWrapper) Finalize()
  • func (_ *TestFixedDefaultTypeWrapper) Get(i int) types.Field
  • func (_ *TestFixedDefaultTypeWrapper) NullField(int)
  • func (_ *TestFixedDefaultTypeWrapper) SetBoolean(v bool)
  • func (r *TestFixedDefaultTypeWrapper) SetBytes(v []byte)
  • func (_ *TestFixedDefaultTypeWrapper) SetDefault(i int)
  • func (_ *TestFixedDefaultTypeWrapper) SetDouble(v float64)
  • func (_ *TestFixedDefaultTypeWrapper) SetFloat(v float32)
  • func (_ *TestFixedDefaultTypeWrapper) SetInt(v int32)
  • func (_ *TestFixedDefaultTypeWrapper) SetLong(v int64)
  • func (_ *TestFixedDefaultTypeWrapper) SetString(v string)
  • func (_ *TestFixedDefaultTypeWrapper) SetUnionElem(v int64)

Constants

const FixedDefaultTestRecordAvroCRC64Fingerprint = "\xac\xb5kw\x1eWK\xcf"

Functions

func NewFixedDefaultTestRecordWriter

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

Types

type FixedDefaultTestRecord

type FixedDefaultTestRecord struct {
	FixedField TestFixedDefaultType `json:"FixedField"`
}

func DeserializeFixedDefaultTestRecord

func DeserializeFixedDefaultTestRecord(r io.Reader) (FixedDefaultTestRecord, error)

func DeserializeFixedDefaultTestRecordFromSchema

func DeserializeFixedDefaultTestRecordFromSchema(r io.Reader, schema string) (FixedDefaultTestRecord, error)

func NewFixedDefaultTestRecord

func NewFixedDefaultTestRecord() FixedDefaultTestRecord

func (FixedDefaultTestRecord) AppendArray

func (_ FixedDefaultTestRecord) AppendArray() types.Field

func (FixedDefaultTestRecord) AppendMap

func (_ FixedDefaultTestRecord) AppendMap(key string) types.Field

func (FixedDefaultTestRecord) AvroCRC64Fingerprint

func (_ FixedDefaultTestRecord) AvroCRC64Fingerprint() []byte

func (FixedDefaultTestRecord) Finalize

func (_ FixedDefaultTestRecord) Finalize()

func (*FixedDefaultTestRecord) Get

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

func (FixedDefaultTestRecord) MarshalJSON

func (r FixedDefaultTestRecord) MarshalJSON() ([]byte, error)

func (*FixedDefaultTestRecord) NullField

func (r *FixedDefaultTestRecord) NullField(i int)

func (FixedDefaultTestRecord) Schema

func (r FixedDefaultTestRecord) Schema() string

func (FixedDefaultTestRecord) SchemaName

func (r FixedDefaultTestRecord) SchemaName() string

func (FixedDefaultTestRecord) Serialize

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

func (FixedDefaultTestRecord) SetBoolean

func (_ FixedDefaultTestRecord) SetBoolean(v bool)

func (FixedDefaultTestRecord) SetBytes

func (_ FixedDefaultTestRecord) SetBytes(v []byte)

func (*FixedDefaultTestRecord) SetDefault

func (r *FixedDefaultTestRecord) SetDefault(i int)

func (FixedDefaultTestRecord) SetDouble

func (_ FixedDefaultTestRecord) SetDouble(v float64)

func (FixedDefaultTestRecord) SetFloat

func (_ FixedDefaultTestRecord) SetFloat(v float32)

func (FixedDefaultTestRecord) SetInt

func (_ FixedDefaultTestRecord) SetInt(v int32)

func (FixedDefaultTestRecord) SetLong

func (_ FixedDefaultTestRecord) SetLong(v int64)

func (FixedDefaultTestRecord) SetString

func (_ FixedDefaultTestRecord) SetString(v string)

func (FixedDefaultTestRecord) SetUnionElem

func (_ FixedDefaultTestRecord) SetUnionElem(v int64)

func (*FixedDefaultTestRecord) UnmarshalJSON

func (r *FixedDefaultTestRecord) UnmarshalJSON(data []byte) error

type FixedDefaultTestRecordReader

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

container reader

func NewFixedDefaultTestRecordReader

func NewFixedDefaultTestRecordReader(r io.Reader) (*FixedDefaultTestRecordReader, error)

func (FixedDefaultTestRecordReader) Read

func (r FixedDefaultTestRecordReader) Read() (FixedDefaultTestRecord, error)

type TestFixedDefaultType

type TestFixedDefaultType [12]byte

func (TestFixedDefaultType) MarshalJSON

func (b TestFixedDefaultType) MarshalJSON() ([]byte, error)

func (*TestFixedDefaultType) UnmarshalJSON

func (b *TestFixedDefaultType) UnmarshalJSON(data []byte) error

type TestFixedDefaultTypeWrapper

type TestFixedDefaultTypeWrapper struct {
	Target *TestFixedDefaultType
}

func (*TestFixedDefaultTypeWrapper) AppendArray

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

func (*TestFixedDefaultTypeWrapper) AppendMap

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

func (*TestFixedDefaultTypeWrapper) Finalize

func (_ *TestFixedDefaultTypeWrapper) Finalize()

func (*TestFixedDefaultTypeWrapper) Get

func (_ *TestFixedDefaultTypeWrapper) Get(i int) types.Field

func (*TestFixedDefaultTypeWrapper) NullField

func (_ *TestFixedDefaultTypeWrapper) NullField(int)

func (*TestFixedDefaultTypeWrapper) SetBoolean

func (_ *TestFixedDefaultTypeWrapper) SetBoolean(v bool)

func (*TestFixedDefaultTypeWrapper) SetBytes

func (r *TestFixedDefaultTypeWrapper) SetBytes(v []byte)

func (*TestFixedDefaultTypeWrapper) SetDefault

func (_ *TestFixedDefaultTypeWrapper) SetDefault(i int)

func (*TestFixedDefaultTypeWrapper) SetDouble

func (_ *TestFixedDefaultTypeWrapper) SetDouble(v float64)

func (*TestFixedDefaultTypeWrapper) SetFloat

func (_ *TestFixedDefaultTypeWrapper) SetFloat(v float32)

func (*TestFixedDefaultTypeWrapper) SetInt

func (_ *TestFixedDefaultTypeWrapper) SetInt(v int32)

func (*TestFixedDefaultTypeWrapper) SetLong

func (_ *TestFixedDefaultTypeWrapper) SetLong(v int64)

func (*TestFixedDefaultTypeWrapper) SetString

func (_ *TestFixedDefaultTypeWrapper) SetString(v string)

func (*TestFixedDefaultTypeWrapper) SetUnionElem

func (_ *TestFixedDefaultTypeWrapper) SetUnionElem(v int64)