avro

Documentation

Overview

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

• SOURCE:
• schema.avsc

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

• SOURCE:
• schema.avsc

Index

• Constants
• func NewNameConflictTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type NameConflictTestRecord
  • func DeserializeNameConflictTestRecord(r io.Reader) (*NameConflictTestRecord, error)
  • func DeserializeNameConflictTestRecordFromSchema(r io.Reader, schema string) (*NameConflictTestRecord, error)
  • func NewNameConflictTestRecord() *NameConflictTestRecord
  • func (_ *NameConflictTestRecord) AppendArray() types.Field
  • func (_ *NameConflictTestRecord) AppendMap(key string) types.Field
  • func (_ *NameConflictTestRecord) AvroCRC64Fingerprint() []byte
  • func (_ *NameConflictTestRecord) Finalize()
  • func (r *NameConflictTestRecord) Get(i int) types.Field
  • func (r *NameConflictTestRecord) NullField(i int)
  • func (r *NameConflictTestRecord) Schema() string
  • func (r *NameConflictTestRecord) SchemaName() string
  • func (r *NameConflictTestRecord) Serialize(w io.Writer) error
  • func (_ *NameConflictTestRecord) SetBoolean(v bool)
  • func (_ *NameConflictTestRecord) SetBytes(v []byte)
  • func (r *NameConflictTestRecord) SetDefault(i int)
  • func (_ *NameConflictTestRecord) SetDouble(v float64)
  • func (_ *NameConflictTestRecord) SetFloat(v float32)
  • func (_ *NameConflictTestRecord) SetInt(v int32)
  • func (_ *NameConflictTestRecord) SetLong(v int64)
  • func (_ *NameConflictTestRecord) SetString(v string)
  • func (_ *NameConflictTestRecord) SetUnionElem(v int64)
• type NameConflictTestRecordReader
  • func NewNameConflictTestRecordReader(r io.Reader) (*NameConflictTestRecordReader, error)
  • func (r NameConflictTestRecordReader) Read() (*NameConflictTestRecord, error)

Constants

const NameConflictTestRecordAvroCRC64Fingerprint = "\xcesIh9\x9f&\b"

Functions

func NewNameConflictTestRecordWriter

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

Types

type NameConflictTestRecord

type NameConflictTestRecord struct {
	Field_Schema bool `json:"Schema"`

	Field_Serialize bool `json:"Serialize"`

	Field_SchemaName bool `json:"SchemaName"`

	Field_MarshalJSON bool `json:"MarshalJSON"`

	Field_UnmarshalJSON bool `json:"UnmarshalJSON"`

	Field_AvroCRC64Fingerprint bool `json:"AvroCRC64Fingerprint"`

	Field_SetBoolean bool `json:"SetBoolean"`

	Field_SetInt bool `json:"SetInt"`

	Field_SetLong bool `json:"SetLong"`

	Field_SetFloat bool `json:"SetFloat"`

	Field_SetDouble bool `json:"SetDouble"`

	Field_SetBytes bool `json:"SetBytes"`

	Field_SetString bool `json:"SetString"`

	Field_Get bool `json:"Get"`

	Field_SetDefault bool `json:"SetDefault"`

	Field_AppendMap bool `json:"AppendMap"`

	Field_AppendArray bool `json:"AppendArray"`

	Field_NullField bool `json:"NullField"`

	Field_Finalize bool `json:"Finalize"`
}

func DeserializeNameConflictTestRecord

func DeserializeNameConflictTestRecord(r io.Reader) (*NameConflictTestRecord, error)

func DeserializeNameConflictTestRecordFromSchema

func DeserializeNameConflictTestRecordFromSchema(r io.Reader, schema string) (*NameConflictTestRecord, error)

func NewNameConflictTestRecord

func NewNameConflictTestRecord() *NameConflictTestRecord

func (*NameConflictTestRecord) AppendArray

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

func (*NameConflictTestRecord) AppendMap

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

func (*NameConflictTestRecord) AvroCRC64Fingerprint

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

func (*NameConflictTestRecord) Finalize

func (_ *NameConflictTestRecord) Finalize()

func (*NameConflictTestRecord) Get

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

func (*NameConflictTestRecord) NullField

func (r *NameConflictTestRecord) NullField(i int)

func (*NameConflictTestRecord) Schema

func (r *NameConflictTestRecord) Schema() string

func (*NameConflictTestRecord) SchemaName

func (r *NameConflictTestRecord) SchemaName() string

func (*NameConflictTestRecord) Serialize

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

func (*NameConflictTestRecord) SetBoolean

func (_ *NameConflictTestRecord) SetBoolean(v bool)

func (*NameConflictTestRecord) SetBytes

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

func (*NameConflictTestRecord) SetDefault

func (r *NameConflictTestRecord) SetDefault(i int)

func (*NameConflictTestRecord) SetDouble

func (_ *NameConflictTestRecord) SetDouble(v float64)

func (*NameConflictTestRecord) SetFloat

func (_ *NameConflictTestRecord) SetFloat(v float32)

func (*NameConflictTestRecord) SetInt

func (_ *NameConflictTestRecord) SetInt(v int32)

func (*NameConflictTestRecord) SetLong

func (_ *NameConflictTestRecord) SetLong(v int64)

func (*NameConflictTestRecord) SetString

func (_ *NameConflictTestRecord) SetString(v string)

func (*NameConflictTestRecord) SetUnionElem

func (_ *NameConflictTestRecord) SetUnionElem(v int64)

type NameConflictTestRecordReader

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

container reader

func NewNameConflictTestRecordReader

func NewNameConflictTestRecordReader(r io.Reader) (*NameConflictTestRecordReader, error)

func (NameConflictTestRecordReader) Read

func (r NameConflictTestRecordReader) Read() (*NameConflictTestRecord, error)