avro

Documentation

Overview

Code generated by Skaidus. DO NOT EDIT.

• SOURCE:
• schema.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCE:
• schema.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCE:
• schema.avsc

Index

• Constants
• func NewPrimitiveTestRecordWriter(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) HintSize(int)
  • 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 PrimitiveTestRecord
  • func DeserializePrimitiveTestRecord(r io.Reader) (PrimitiveTestRecord, error)
  • func DeserializePrimitiveTestRecordFromSchema(r io.Reader, schema string) (PrimitiveTestRecord, error)
  • func NewPrimitiveTestRecord() PrimitiveTestRecord
  • func (_ PrimitiveTestRecord) AppendArray() types.Field
  • func (_ PrimitiveTestRecord) AppendMap(key string) types.Field
  • func (_ PrimitiveTestRecord) AvroCRC64Fingerprint() []byte
  • func (_ PrimitiveTestRecord) Finalize()
  • func (r *PrimitiveTestRecord) Get(i int) types.Field
  • func (_ PrimitiveTestRecord) HintSize(int)
  • func (r PrimitiveTestRecord) MarshalJSON() ([]byte, error)
  • func (r *PrimitiveTestRecord) NullField(i int)
  • func (r PrimitiveTestRecord) Schema() string
  • func (r PrimitiveTestRecord) SchemaName() string
  • func (r PrimitiveTestRecord) Serialize(w io.Writer) error
  • func (_ PrimitiveTestRecord) SetBoolean(v bool)
  • func (_ PrimitiveTestRecord) SetBytes(v []byte)
  • func (r *PrimitiveTestRecord) SetDefault(i int)
  • func (_ PrimitiveTestRecord) SetDouble(v float64)
  • func (_ PrimitiveTestRecord) SetFloat(v float32)
  • func (_ PrimitiveTestRecord) SetInt(v int32)
  • func (_ PrimitiveTestRecord) SetLong(v int64)
  • func (_ PrimitiveTestRecord) SetString(v string)
  • func (_ PrimitiveTestRecord) SetUnionElem(v int64)
  • func (r *PrimitiveTestRecord) UnmarshalJSON(data []byte) error
• type PrimitiveTestRecordReader
  • func NewPrimitiveTestRecordReader(r io.Reader) (*PrimitiveTestRecordReader, error)
  • func (r PrimitiveTestRecordReader) Read() (PrimitiveTestRecord, error)

Constants

const PrimitiveTestRecordAvroCRC64Fingerprint = "۲\x16\xe9\xfet@\x13"

Functions

func NewPrimitiveTestRecordWriter

func NewPrimitiveTestRecordWriter(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) HintSize

func (b BytesWrapper) HintSize(int)

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 PrimitiveTestRecord

type PrimitiveTestRecord struct {
	// int field
	IntField int32 `json:"IntField"`

	LongField int64 `json:"LongField"`

	FloatField float32 `json:"FloatField"`

	DoubleField float64 `json:"DoubleField"`

	StringField string `json:"StringField"`

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

primitive record

func DeserializePrimitiveTestRecord

func DeserializePrimitiveTestRecord(r io.Reader) (PrimitiveTestRecord, error)

func DeserializePrimitiveTestRecordFromSchema

func DeserializePrimitiveTestRecordFromSchema(r io.Reader, schema string) (PrimitiveTestRecord, error)

func NewPrimitiveTestRecord

func NewPrimitiveTestRecord() PrimitiveTestRecord

func (PrimitiveTestRecord) AppendArray

func (_ PrimitiveTestRecord) AppendArray() types.Field

func (PrimitiveTestRecord) AppendMap

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

func (PrimitiveTestRecord) AvroCRC64Fingerprint

func (_ PrimitiveTestRecord) AvroCRC64Fingerprint() []byte

func (PrimitiveTestRecord) Finalize

func (_ PrimitiveTestRecord) Finalize()

func (*PrimitiveTestRecord) Get

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

func (PrimitiveTestRecord) HintSize

func (_ PrimitiveTestRecord) HintSize(int)

func (PrimitiveTestRecord) MarshalJSON

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

func (*PrimitiveTestRecord) NullField

func (r *PrimitiveTestRecord) NullField(i int)

func (PrimitiveTestRecord) Schema

func (r PrimitiveTestRecord) Schema() string

func (PrimitiveTestRecord) SchemaName

func (r PrimitiveTestRecord) SchemaName() string

func (PrimitiveTestRecord) Serialize

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

func (PrimitiveTestRecord) SetBoolean

func (_ PrimitiveTestRecord) SetBoolean(v bool)

func (PrimitiveTestRecord) SetBytes

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

func (*PrimitiveTestRecord) SetDefault

func (r *PrimitiveTestRecord) SetDefault(i int)

func (PrimitiveTestRecord) SetDouble

func (_ PrimitiveTestRecord) SetDouble(v float64)

func (PrimitiveTestRecord) SetFloat

func (_ PrimitiveTestRecord) SetFloat(v float32)

func (PrimitiveTestRecord) SetInt

func (_ PrimitiveTestRecord) SetInt(v int32)

func (PrimitiveTestRecord) SetLong

func (_ PrimitiveTestRecord) SetLong(v int64)

func (PrimitiveTestRecord) SetString

func (_ PrimitiveTestRecord) SetString(v string)

func (PrimitiveTestRecord) SetUnionElem

func (_ PrimitiveTestRecord) SetUnionElem(v int64)

func (*PrimitiveTestRecord) UnmarshalJSON

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

type PrimitiveTestRecordReader

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

container reader

func NewPrimitiveTestRecordReader

func NewPrimitiveTestRecordReader(r io.Reader) (*PrimitiveTestRecordReader, error)

func (PrimitiveTestRecordReader) Read

func (r PrimitiveTestRecordReader) Read() (PrimitiveTestRecord, error)