avro

Documentation

Overview

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

• SOURCE:
• schema.avsc

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

• SOURCE:
• schema.avsc

Index

• Constants
• func NewAliasRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type AliasRecord
  • func DeserializeAliasRecord(r io.Reader) (AliasRecord, error)
  • func DeserializeAliasRecordFromSchema(r io.Reader, schema string) (AliasRecord, error)
  • func NewAliasRecord() AliasRecord
  • func (_ AliasRecord) AppendArray() types.Field
  • func (_ AliasRecord) AppendMap(key string) types.Field
  • func (_ AliasRecord) AvroCRC64Fingerprint() []byte
  • func (_ AliasRecord) Finalize()
  • func (r *AliasRecord) Get(i int) types.Field
  • func (_ AliasRecord) HintSize(int)
  • func (r AliasRecord) MarshalJSON() ([]byte, error)
  • func (r *AliasRecord) NullField(i int)
  • func (r AliasRecord) Schema() string
  • func (r AliasRecord) SchemaName() string
  • func (r AliasRecord) Serialize(w io.Writer) error
  • func (_ AliasRecord) SetBoolean(v bool)
  • func (_ AliasRecord) SetBytes(v []byte)
  • func (r *AliasRecord) SetDefault(i int)
  • func (_ AliasRecord) SetDouble(v float64)
  • func (_ AliasRecord) SetFloat(v float32)
  • func (_ AliasRecord) SetInt(v int32)
  • func (_ AliasRecord) SetLong(v int64)
  • func (_ AliasRecord) SetString(v string)
  • func (_ AliasRecord) SetUnionElem(v int64)
  • func (r *AliasRecord) UnmarshalJSON(data []byte) error
• type AliasRecordReader
  • func NewAliasRecordReader(r io.Reader) (*AliasRecordReader, error)
  • func (r AliasRecordReader) Read() (AliasRecord, error)

Constants

const AliasRecordAvroCRC64Fingerprint = "B~_@rz\xdb\xc7"

Functions

func NewAliasRecordWriter

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

Types

type AliasRecord

type AliasRecord struct {
	A string `json:"a"`

	C string `json:"c"`
}

func DeserializeAliasRecord

func DeserializeAliasRecord(r io.Reader) (AliasRecord, error)

func DeserializeAliasRecordFromSchema

func DeserializeAliasRecordFromSchema(r io.Reader, schema string) (AliasRecord, error)

func NewAliasRecord

func NewAliasRecord() AliasRecord

func (AliasRecord) AppendArray

func (_ AliasRecord) AppendArray() types.Field

func (AliasRecord) AppendMap

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

func (AliasRecord) AvroCRC64Fingerprint

func (_ AliasRecord) AvroCRC64Fingerprint() []byte

func (AliasRecord) Finalize

func (_ AliasRecord) Finalize()

func (*AliasRecord) Get

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

func (AliasRecord) HintSize

func (_ AliasRecord) HintSize(int)

func (AliasRecord) MarshalJSON

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

func (*AliasRecord) NullField

func (r *AliasRecord) NullField(i int)

func (AliasRecord) Schema

func (r AliasRecord) Schema() string

func (AliasRecord) SchemaName

func (r AliasRecord) SchemaName() string

func (AliasRecord) Serialize

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

func (AliasRecord) SetBoolean

func (_ AliasRecord) SetBoolean(v bool)

func (AliasRecord) SetBytes

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

func (*AliasRecord) SetDefault

func (r *AliasRecord) SetDefault(i int)

func (AliasRecord) SetDouble

func (_ AliasRecord) SetDouble(v float64)

func (AliasRecord) SetFloat

func (_ AliasRecord) SetFloat(v float32)

func (AliasRecord) SetInt

func (_ AliasRecord) SetInt(v int32)

func (AliasRecord) SetLong

func (_ AliasRecord) SetLong(v int64)

func (AliasRecord) SetString

func (_ AliasRecord) SetString(v string)

func (AliasRecord) SetUnionElem

func (_ AliasRecord) SetUnionElem(v int64)

func (*AliasRecord) UnmarshalJSON

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

type AliasRecordReader

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

container reader

func NewAliasRecordReader

func NewAliasRecordReader(r io.Reader) (*AliasRecordReader, error)

func (AliasRecordReader) Read

func (r AliasRecordReader) Read() (AliasRecord, error)