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 NewNameConflictTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type Bytes
  • func (b Bytes) MarshalJSON() ([]byte, error)
  • func (b *Bytes) UnmarshalJSON(data []byte) error
• type BytesWrapper
  • func (b BytesWrapper) AppendArray() types.Field
  • func (b BytesWrapper) AppendMap(key string) types.Field
  • func (b BytesWrapper) Finalize()
  • func (b BytesWrapper) Get(i int) types.Field
  • func (b BytesWrapper) NullField(int)
  • func (b BytesWrapper) SetBoolean(v bool)
  • func (b BytesWrapper) SetBytes(v []byte)
  • func (b BytesWrapper) SetDefault(i int)
  • func (b BytesWrapper) SetDouble(v float64)
  • func (b BytesWrapper) SetFloat(v float32)
  • func (b BytesWrapper) SetInt(v int32)
  • func (b BytesWrapper) SetLong(v int64)
  • func (b BytesWrapper) SetString(v string)
  • func (b BytesWrapper) SetUnionElem(v int64)
• 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) MarshalJSON() ([]byte, error)
  • 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)
  • func (r *NameConflictTestRecord) UnmarshalJSON(data []byte) error
• 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 Bytes

type Bytes []byte

func (Bytes) MarshalJSON

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

func (*Bytes) UnmarshalJSON

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

type BytesWrapper

type BytesWrapper struct {
	Target *Bytes
}

func (BytesWrapper) AppendArray

func (b BytesWrapper) AppendArray() types.Field

func (BytesWrapper) AppendMap

func (b BytesWrapper) AppendMap(key string) types.Field

func (BytesWrapper) Finalize

func (b BytesWrapper) Finalize()

func (BytesWrapper) Get

func (b BytesWrapper) Get(i int) types.Field

func (BytesWrapper) NullField

func (b BytesWrapper) NullField(int)

func (BytesWrapper) SetBoolean

func (b BytesWrapper) SetBoolean(v bool)

func (BytesWrapper) SetBytes

func (b BytesWrapper) SetBytes(v []byte)

func (BytesWrapper) SetDefault

func (b BytesWrapper) SetDefault(i int)

func (BytesWrapper) SetDouble

func (b BytesWrapper) SetDouble(v float64)

func (BytesWrapper) SetFloat

func (b BytesWrapper) SetFloat(v float32)

func (BytesWrapper) SetInt

func (b BytesWrapper) SetInt(v int32)

func (BytesWrapper) SetLong

func (b BytesWrapper) SetLong(v int64)

func (BytesWrapper) SetString

func (b BytesWrapper) SetString(v string)

func (BytesWrapper) SetUnionElem

func (b BytesWrapper) SetUnionElem(v int64)

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) MarshalJSON

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

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)

func (*NameConflictTestRecord) UnmarshalJSON

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

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)