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 NewEnumTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type EnumTestRecord
  • func DeserializeEnumTestRecord(r io.Reader) (EnumTestRecord, error)
  • func DeserializeEnumTestRecordFromSchema(r io.Reader, schema string) (EnumTestRecord, error)
  • func NewEnumTestRecord() EnumTestRecord
  • func (_ EnumTestRecord) AppendArray() types.Field
  • func (_ EnumTestRecord) AppendMap(key string) types.Field
  • func (_ EnumTestRecord) AvroCRC64Fingerprint() []byte
  • func (_ EnumTestRecord) Finalize()
  • func (r *EnumTestRecord) Get(i int) types.Field
  • func (_ EnumTestRecord) HintSize(int)
  • func (r EnumTestRecord) MarshalJSON() ([]byte, error)
  • func (r *EnumTestRecord) NullField(i int)
  • func (r EnumTestRecord) Schema() string
  • func (r EnumTestRecord) SchemaName() string
  • func (r EnumTestRecord) Serialize(w io.Writer) error
  • func (_ EnumTestRecord) SetBoolean(v bool)
  • func (_ EnumTestRecord) SetBytes(v []byte)
  • func (r *EnumTestRecord) SetDefault(i int)
  • func (_ EnumTestRecord) SetDouble(v float64)
  • func (_ EnumTestRecord) SetFloat(v float32)
  • func (_ EnumTestRecord) SetInt(v int32)
  • func (_ EnumTestRecord) SetLong(v int64)
  • func (_ EnumTestRecord) SetString(v string)
  • func (_ EnumTestRecord) SetUnionElem(v int64)
  • func (r *EnumTestRecord) UnmarshalJSON(data []byte) error
• type EnumTestRecordReader
  • func NewEnumTestRecordReader(r io.Reader) (*EnumTestRecordReader, error)
  • func (r EnumTestRecordReader) Read() (EnumTestRecord, error)
• type TestEnumType
  • func NewTestEnumTypeValue(raw string) (r TestEnumType, err error)
  • func (b TestEnumType) MarshalJSON() ([]byte, error)
  • func (e TestEnumType) String() string
  • func (b *TestEnumType) UnmarshalJSON(data []byte) error
• type TestEnumTypeWrapper
  • func (b TestEnumTypeWrapper) AppendArray() types.Field
  • func (b TestEnumTypeWrapper) AppendMap(key string) types.Field
  • func (b TestEnumTypeWrapper) Finalize()
  • func (b TestEnumTypeWrapper) Get(i int) types.Field
  • func (b TestEnumTypeWrapper) HintSize(int)
  • func (b TestEnumTypeWrapper) NullField(int)
  • func (b TestEnumTypeWrapper) SetBoolean(v bool)
  • func (b TestEnumTypeWrapper) SetBytes(v []byte)
  • func (b TestEnumTypeWrapper) SetDefault(i int)
  • func (b TestEnumTypeWrapper) SetDouble(v float64)
  • func (b TestEnumTypeWrapper) SetFloat(v float32)
  • func (b TestEnumTypeWrapper) SetInt(v int32)
  • func (b TestEnumTypeWrapper) SetLong(v int64)
  • func (b TestEnumTypeWrapper) SetString(v string)
  • func (b TestEnumTypeWrapper) SetUnionElem(v int64)

Constants

const EnumTestRecordAvroCRC64Fingerprint = "C븍h\xc5\xeb\x96"

Functions

func NewEnumTestRecordWriter

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

Types

type EnumTestRecord

type EnumTestRecord struct {
	EnumField TestEnumType `json:"EnumField"`
}

func DeserializeEnumTestRecord

func DeserializeEnumTestRecord(r io.Reader) (EnumTestRecord, error)

func DeserializeEnumTestRecordFromSchema

func DeserializeEnumTestRecordFromSchema(r io.Reader, schema string) (EnumTestRecord, error)

func NewEnumTestRecord

func NewEnumTestRecord() EnumTestRecord

func (EnumTestRecord) AppendArray

func (_ EnumTestRecord) AppendArray() types.Field

func (EnumTestRecord) AppendMap

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

func (EnumTestRecord) AvroCRC64Fingerprint

func (_ EnumTestRecord) AvroCRC64Fingerprint() []byte

func (EnumTestRecord) Finalize

func (_ EnumTestRecord) Finalize()

func (*EnumTestRecord) Get

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

func (EnumTestRecord) HintSize

func (_ EnumTestRecord) HintSize(int)

func (EnumTestRecord) MarshalJSON

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

func (*EnumTestRecord) NullField

func (r *EnumTestRecord) NullField(i int)

func (EnumTestRecord) Schema

func (r EnumTestRecord) Schema() string

func (EnumTestRecord) SchemaName

func (r EnumTestRecord) SchemaName() string

func (EnumTestRecord) Serialize

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

func (EnumTestRecord) SetBoolean

func (_ EnumTestRecord) SetBoolean(v bool)

func (EnumTestRecord) SetBytes

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

func (*EnumTestRecord) SetDefault

func (r *EnumTestRecord) SetDefault(i int)

func (EnumTestRecord) SetDouble

func (_ EnumTestRecord) SetDouble(v float64)

func (EnumTestRecord) SetFloat

func (_ EnumTestRecord) SetFloat(v float32)

func (EnumTestRecord) SetInt

func (_ EnumTestRecord) SetInt(v int32)

func (EnumTestRecord) SetLong

func (_ EnumTestRecord) SetLong(v int64)

func (EnumTestRecord) SetString

func (_ EnumTestRecord) SetString(v string)

func (EnumTestRecord) SetUnionElem

func (_ EnumTestRecord) SetUnionElem(v int64)

func (*EnumTestRecord) UnmarshalJSON

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

type EnumTestRecordReader

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

container reader

func NewEnumTestRecordReader

func NewEnumTestRecordReader(r io.Reader) (*EnumTestRecordReader, error)

func (EnumTestRecordReader) Read

func (r EnumTestRecordReader) Read() (EnumTestRecord, error)

type TestEnumType

type TestEnumType int32

Test enum

const (
	TestEnumTypeTestSymbol1 TestEnumType = 0
	TestEnumTypeTestSymbol2 TestEnumType = 1
	TestEnumTypeTestSymbol3 TestEnumType = 2
)

func NewTestEnumTypeValue

func NewTestEnumTypeValue(raw string) (r TestEnumType, err error)

func (TestEnumType) MarshalJSON

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

func (TestEnumType) String

func (e TestEnumType) String() string

func (*TestEnumType) UnmarshalJSON

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

type TestEnumTypeWrapper

type TestEnumTypeWrapper struct {
	Target *TestEnumType
}

func (TestEnumTypeWrapper) AppendArray

func (b TestEnumTypeWrapper) AppendArray() types.Field

func (TestEnumTypeWrapper) AppendMap

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

func (TestEnumTypeWrapper) Finalize

func (b TestEnumTypeWrapper) Finalize()

func (TestEnumTypeWrapper) Get

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

func (TestEnumTypeWrapper) HintSize

func (b TestEnumTypeWrapper) HintSize(int)

func (TestEnumTypeWrapper) NullField

func (b TestEnumTypeWrapper) NullField(int)

func (TestEnumTypeWrapper) SetBoolean

func (b TestEnumTypeWrapper) SetBoolean(v bool)

func (TestEnumTypeWrapper) SetBytes

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

func (TestEnumTypeWrapper) SetDefault

func (b TestEnumTypeWrapper) SetDefault(i int)

func (TestEnumTypeWrapper) SetDouble

func (b TestEnumTypeWrapper) SetDouble(v float64)

func (TestEnumTypeWrapper) SetFloat

func (b TestEnumTypeWrapper) SetFloat(v float32)

func (TestEnumTypeWrapper) SetInt

func (b TestEnumTypeWrapper) SetInt(v int32)

func (TestEnumTypeWrapper) SetLong

func (b TestEnumTypeWrapper) SetLong(v int64)

func (TestEnumTypeWrapper) SetString

func (b TestEnumTypeWrapper) SetString(v string)

func (TestEnumTypeWrapper) SetUnionElem

func (b TestEnumTypeWrapper) SetUnionElem(v int64)