avro

package
v10.5.0-mm Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 3, 2023 License: MIT Imports: 8 Imported by: 0

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

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

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

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Index

Constants

View Source 
const MapTestRecordAvroCRC64Fingerprint = "<?\x18\xa0\a\xdf^\x9e"

Variables

This section is empty.

Functions

func NewMapTestRecordWriter 

func NewMapTestRecordWriter(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 MapBoolWrapper 

type MapBoolWrapper struct {
	Target *map[string]bool
	// contains filtered or unexported fields
}

func (*MapBoolWrapper) AppendArray 

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

func (*MapBoolWrapper) AppendMap 

func (r *MapBoolWrapper) AppendMap(key string) types.Field

func (*MapBoolWrapper) Finalize 

func (r *MapBoolWrapper) Finalize()

func (*MapBoolWrapper) Get 

func (_ *MapBoolWrapper) Get(i int) types.Field

func (*MapBoolWrapper) HintSize 

func (r *MapBoolWrapper) HintSize(s int)

func (*MapBoolWrapper) NullField 

func (r *MapBoolWrapper) NullField(_ int)

func (*MapBoolWrapper) SetBoolean 

func (_ *MapBoolWrapper) SetBoolean(v bool)

func (*MapBoolWrapper) SetBytes 

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

func (*MapBoolWrapper) SetDefault 

func (_ *MapBoolWrapper) SetDefault(i int)

func (*MapBoolWrapper) SetDouble 

func (_ *MapBoolWrapper) SetDouble(v float64)

func (*MapBoolWrapper) SetFloat 

func (_ *MapBoolWrapper) SetFloat(v float32)

func (*MapBoolWrapper) SetInt 

func (_ *MapBoolWrapper) SetInt(v int32)

func (*MapBoolWrapper) SetLong 

func (_ *MapBoolWrapper) SetLong(v int64)

func (*MapBoolWrapper) SetString 

func (_ *MapBoolWrapper) SetString(v string)

func (*MapBoolWrapper) SetUnionElem 

func (_ *MapBoolWrapper) SetUnionElem(v int64)

type MapBytesWrapper 

type MapBytesWrapper struct {
	Target *map[string]Bytes
	// contains filtered or unexported fields
}

func (*MapBytesWrapper) AppendArray 

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

func (*MapBytesWrapper) AppendMap 

func (r *MapBytesWrapper) AppendMap(key string) types.Field

func (*MapBytesWrapper) Finalize 

func (r *MapBytesWrapper) Finalize()

func (*MapBytesWrapper) Get 

func (_ *MapBytesWrapper) Get(i int) types.Field

func (*MapBytesWrapper) HintSize 

func (r *MapBytesWrapper) HintSize(s int)

func (*MapBytesWrapper) NullField 

func (r *MapBytesWrapper) NullField(_ int)

func (*MapBytesWrapper) SetBoolean 

func (_ *MapBytesWrapper) SetBoolean(v bool)

func (*MapBytesWrapper) SetBytes 

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

func (*MapBytesWrapper) SetDefault 

func (_ *MapBytesWrapper) SetDefault(i int)

func (*MapBytesWrapper) SetDouble 

func (_ *MapBytesWrapper) SetDouble(v float64)

func (*MapBytesWrapper) SetFloat 

func (_ *MapBytesWrapper) SetFloat(v float32)

func (*MapBytesWrapper) SetInt 

func (_ *MapBytesWrapper) SetInt(v int32)

func (*MapBytesWrapper) SetLong 

func (_ *MapBytesWrapper) SetLong(v int64)

func (*MapBytesWrapper) SetString 

func (_ *MapBytesWrapper) SetString(v string)

func (*MapBytesWrapper) SetUnionElem 

func (_ *MapBytesWrapper) SetUnionElem(v int64)

type MapDoubleWrapper 

type MapDoubleWrapper struct {
	Target *map[string]float64
	// contains filtered or unexported fields
}

func (*MapDoubleWrapper) AppendArray 

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

func (*MapDoubleWrapper) AppendMap 

func (r *MapDoubleWrapper) AppendMap(key string) types.Field

func (*MapDoubleWrapper) Finalize 

func (r *MapDoubleWrapper) Finalize()

func (*MapDoubleWrapper) Get 

func (_ *MapDoubleWrapper) Get(i int) types.Field

func (*MapDoubleWrapper) HintSize 

func (r *MapDoubleWrapper) HintSize(s int)

func (*MapDoubleWrapper) NullField 

func (r *MapDoubleWrapper) NullField(_ int)

func (*MapDoubleWrapper) SetBoolean 

func (_ *MapDoubleWrapper) SetBoolean(v bool)

func (*MapDoubleWrapper) SetBytes 

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

func (*MapDoubleWrapper) SetDefault 

func (_ *MapDoubleWrapper) SetDefault(i int)

func (*MapDoubleWrapper) SetDouble 

func (_ *MapDoubleWrapper) SetDouble(v float64)

func (*MapDoubleWrapper) SetFloat 

func (_ *MapDoubleWrapper) SetFloat(v float32)

func (*MapDoubleWrapper) SetInt 

func (_ *MapDoubleWrapper) SetInt(v int32)

func (*MapDoubleWrapper) SetLong 

func (_ *MapDoubleWrapper) SetLong(v int64)

func (*MapDoubleWrapper) SetString 

func (_ *MapDoubleWrapper) SetString(v string)

func (*MapDoubleWrapper) SetUnionElem 

func (_ *MapDoubleWrapper) SetUnionElem(v int64)

type MapFloatWrapper 

type MapFloatWrapper struct {
	Target *map[string]float32
	// contains filtered or unexported fields
}

func (*MapFloatWrapper) AppendArray 

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

func (*MapFloatWrapper) AppendMap 

func (r *MapFloatWrapper) AppendMap(key string) types.Field

func (*MapFloatWrapper) Finalize 

func (r *MapFloatWrapper) Finalize()

func (*MapFloatWrapper) Get 

func (_ *MapFloatWrapper) Get(i int) types.Field

func (*MapFloatWrapper) HintSize 

func (r *MapFloatWrapper) HintSize(s int)

func (*MapFloatWrapper) NullField 

func (r *MapFloatWrapper) NullField(_ int)

func (*MapFloatWrapper) SetBoolean 

func (_ *MapFloatWrapper) SetBoolean(v bool)

func (*MapFloatWrapper) SetBytes 

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

func (*MapFloatWrapper) SetDefault 

func (_ *MapFloatWrapper) SetDefault(i int)

func (*MapFloatWrapper) SetDouble 

func (_ *MapFloatWrapper) SetDouble(v float64)

func (*MapFloatWrapper) SetFloat 

func (_ *MapFloatWrapper) SetFloat(v float32)

func (*MapFloatWrapper) SetInt 

func (_ *MapFloatWrapper) SetInt(v int32)

func (*MapFloatWrapper) SetLong 

func (_ *MapFloatWrapper) SetLong(v int64)

func (*MapFloatWrapper) SetString 

func (_ *MapFloatWrapper) SetString(v string)

func (*MapFloatWrapper) SetUnionElem 

func (_ *MapFloatWrapper) SetUnionElem(v int64)

type MapIntWrapper 

type MapIntWrapper struct {
	Target *map[string]int32
	// contains filtered or unexported fields
}

func (*MapIntWrapper) AppendArray 

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

func (*MapIntWrapper) AppendMap 

func (r *MapIntWrapper) AppendMap(key string) types.Field

func (*MapIntWrapper) Finalize 

func (r *MapIntWrapper) Finalize()

func (*MapIntWrapper) Get 

func (_ *MapIntWrapper) Get(i int) types.Field

func (*MapIntWrapper) HintSize 

func (r *MapIntWrapper) HintSize(s int)

func (*MapIntWrapper) NullField 

func (r *MapIntWrapper) NullField(_ int)

func (*MapIntWrapper) SetBoolean 

func (_ *MapIntWrapper) SetBoolean(v bool)

func (*MapIntWrapper) SetBytes 

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

func (*MapIntWrapper) SetDefault 

func (_ *MapIntWrapper) SetDefault(i int)

func (*MapIntWrapper) SetDouble 

func (_ *MapIntWrapper) SetDouble(v float64)

func (*MapIntWrapper) SetFloat 

func (_ *MapIntWrapper) SetFloat(v float32)

func (*MapIntWrapper) SetInt 

func (_ *MapIntWrapper) SetInt(v int32)

func (*MapIntWrapper) SetLong 

func (_ *MapIntWrapper) SetLong(v int64)

func (*MapIntWrapper) SetString 

func (_ *MapIntWrapper) SetString(v string)

func (*MapIntWrapper) SetUnionElem 

func (_ *MapIntWrapper) SetUnionElem(v int64)

type MapLongWrapper 

type MapLongWrapper struct {
	Target *map[string]int64
	// contains filtered or unexported fields
}

func (*MapLongWrapper) AppendArray 

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

func (*MapLongWrapper) AppendMap 

func (r *MapLongWrapper) AppendMap(key string) types.Field

func (*MapLongWrapper) Finalize 

func (r *MapLongWrapper) Finalize()

func (*MapLongWrapper) Get 

func (_ *MapLongWrapper) Get(i int) types.Field

func (*MapLongWrapper) HintSize 

func (r *MapLongWrapper) HintSize(s int)

func (*MapLongWrapper) NullField 

func (r *MapLongWrapper) NullField(_ int)

func (*MapLongWrapper) SetBoolean 

func (_ *MapLongWrapper) SetBoolean(v bool)

func (*MapLongWrapper) SetBytes 

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

func (*MapLongWrapper) SetDefault 

func (_ *MapLongWrapper) SetDefault(i int)

func (*MapLongWrapper) SetDouble 

func (_ *MapLongWrapper) SetDouble(v float64)

func (*MapLongWrapper) SetFloat 

func (_ *MapLongWrapper) SetFloat(v float32)

func (*MapLongWrapper) SetInt 

func (_ *MapLongWrapper) SetInt(v int32)

func (*MapLongWrapper) SetLong 

func (_ *MapLongWrapper) SetLong(v int64)

func (*MapLongWrapper) SetString 

func (_ *MapLongWrapper) SetString(v string)

func (*MapLongWrapper) SetUnionElem 

func (_ *MapLongWrapper) SetUnionElem(v int64)

type MapStringWrapper 

type MapStringWrapper struct {
	Target *map[string]string
	// contains filtered or unexported fields
}

func (*MapStringWrapper) AppendArray 

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

func (*MapStringWrapper) AppendMap 

func (r *MapStringWrapper) AppendMap(key string) types.Field

func (*MapStringWrapper) Finalize 

func (r *MapStringWrapper) Finalize()

func (*MapStringWrapper) Get 

func (_ *MapStringWrapper) Get(i int) types.Field

func (*MapStringWrapper) HintSize 

func (r *MapStringWrapper) HintSize(s int)

func (*MapStringWrapper) NullField 

func (r *MapStringWrapper) NullField(_ int)

func (*MapStringWrapper) SetBoolean 

func (_ *MapStringWrapper) SetBoolean(v bool)

func (*MapStringWrapper) SetBytes 

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

func (*MapStringWrapper) SetDefault 

func (_ *MapStringWrapper) SetDefault(i int)

func (*MapStringWrapper) SetDouble 

func (_ *MapStringWrapper) SetDouble(v float64)

func (*MapStringWrapper) SetFloat 

func (_ *MapStringWrapper) SetFloat(v float32)

func (*MapStringWrapper) SetInt 

func (_ *MapStringWrapper) SetInt(v int32)

func (*MapStringWrapper) SetLong 

func (_ *MapStringWrapper) SetLong(v int64)

func (*MapStringWrapper) SetString 

func (_ *MapStringWrapper) SetString(v string)

func (*MapStringWrapper) SetUnionElem 

func (_ *MapStringWrapper) SetUnionElem(v int64)

type MapTestRecord 

type MapTestRecord struct {
	IntField map[string]int32 `json:"IntField"`

	LongField map[string]int64 `json:"LongField"`

	DoubleField map[string]float64 `json:"DoubleField"`

	StringField map[string]string `json:"StringField"`

	FloatField map[string]float32 `json:"FloatField"`

	BoolField map[string]bool `json:"BoolField"`

	BytesField map[string]Bytes `json:"BytesField"`
}

func DeserializeMapTestRecord 

func DeserializeMapTestRecord(r io.Reader) (MapTestRecord, error)

func DeserializeMapTestRecordFromSchema 

func DeserializeMapTestRecordFromSchema(r io.Reader, schema string) (MapTestRecord, error)

func NewMapTestRecord 

func NewMapTestRecord() MapTestRecord

func (MapTestRecord) AppendArray 

func (_ MapTestRecord) AppendArray() types.Field

func (MapTestRecord) AppendMap 

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

func (MapTestRecord) AvroCRC64Fingerprint 

func (_ MapTestRecord) AvroCRC64Fingerprint() []byte

func (MapTestRecord) Finalize 

func (_ MapTestRecord) Finalize()

func (*MapTestRecord) Get 

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

func (MapTestRecord) HintSize 

func (_ MapTestRecord) HintSize(int)

func (MapTestRecord) MarshalJSON 

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

func (*MapTestRecord) NullField 

func (r *MapTestRecord) NullField(i int)

func (MapTestRecord) Schema 

func (r MapTestRecord) Schema() string

func (MapTestRecord) SchemaName 

func (r MapTestRecord) SchemaName() string

func (MapTestRecord) Serialize 

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

func (MapTestRecord) SetBoolean 

func (_ MapTestRecord) SetBoolean(v bool)

func (MapTestRecord) SetBytes 

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

func (*MapTestRecord) SetDefault 

func (r *MapTestRecord) SetDefault(i int)

func (MapTestRecord) SetDouble 

func (_ MapTestRecord) SetDouble(v float64)

func (MapTestRecord) SetFloat 

func (_ MapTestRecord) SetFloat(v float32)

func (MapTestRecord) SetInt 

func (_ MapTestRecord) SetInt(v int32)

func (MapTestRecord) SetLong 

func (_ MapTestRecord) SetLong(v int64)

func (MapTestRecord) SetString 

func (_ MapTestRecord) SetString(v string)

func (MapTestRecord) SetUnionElem 

func (_ MapTestRecord) SetUnionElem(v int64)

func (*MapTestRecord) UnmarshalJSON 

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

type MapTestRecordReader 

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

container reader

func NewMapTestRecordReader 

func NewMapTestRecordReader(r io.Reader) (*MapTestRecordReader, error)

func (MapTestRecordReader) Read 

func (r MapTestRecordReader) Read() (MapTestRecord, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.