avro

package
v10.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2023 License: MIT Imports: 7 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

Index

Constants

View Source 
const ComplexUnionTestRecordAvroCRC64Fingerprint = ")h\bbm{\xe0\xbe"
View Source 
const NestedUnionRecordAvroCRC64Fingerprint = "#\xb6\xed\xa0\x87F=\xef"

Variables

This section is empty.

Functions

func NewComplexUnionTestRecordWriter 

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

func NewNestedUnionRecordWriter 

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

Types

type ArrayIntWrapper 

type ArrayIntWrapper struct {
	Target *[]int32
}

func (ArrayIntWrapper) AppendArray 

func (r ArrayIntWrapper) AppendArray() types.Field

func (ArrayIntWrapper) AppendMap 

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

func (ArrayIntWrapper) Finalize 

func (_ ArrayIntWrapper) Finalize()

func (ArrayIntWrapper) Get 

func (_ ArrayIntWrapper) Get(i int) types.Field

func (ArrayIntWrapper) HintSize 

func (r ArrayIntWrapper) HintSize(s int)

func (ArrayIntWrapper) NullField 

func (r ArrayIntWrapper) NullField(i int)

func (ArrayIntWrapper) SetBoolean 

func (_ ArrayIntWrapper) SetBoolean(v bool)

func (ArrayIntWrapper) SetBytes 

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

func (ArrayIntWrapper) SetDefault 

func (_ ArrayIntWrapper) SetDefault(i int)

func (ArrayIntWrapper) SetDouble 

func (_ ArrayIntWrapper) SetDouble(v float64)

func (ArrayIntWrapper) SetFloat 

func (_ ArrayIntWrapper) SetFloat(v float32)

func (ArrayIntWrapper) SetInt 

func (_ ArrayIntWrapper) SetInt(v int32)

func (ArrayIntWrapper) SetLong 

func (_ ArrayIntWrapper) SetLong(v int64)

func (ArrayIntWrapper) SetString 

func (_ ArrayIntWrapper) SetString(v string)

func (ArrayIntWrapper) SetUnionElem 

func (_ ArrayIntWrapper) SetUnionElem(v int64)

type ComplexUnionTestRecord 

type ComplexUnionTestRecord struct {
	UnionField *UnionNullArrayIntMapIntNestedUnionRecord `json:"UnionField"`
}

func DeserializeComplexUnionTestRecord 

func DeserializeComplexUnionTestRecord(r io.Reader) (ComplexUnionTestRecord, error)

func DeserializeComplexUnionTestRecordFromSchema 

func DeserializeComplexUnionTestRecordFromSchema(r io.Reader, schema string) (ComplexUnionTestRecord, error)

func NewComplexUnionTestRecord 

func NewComplexUnionTestRecord() ComplexUnionTestRecord

func (ComplexUnionTestRecord) AppendArray 

func (_ ComplexUnionTestRecord) AppendArray() types.Field

func (ComplexUnionTestRecord) AppendMap 

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

func (ComplexUnionTestRecord) AvroCRC64Fingerprint 

func (_ ComplexUnionTestRecord) AvroCRC64Fingerprint() []byte

func (ComplexUnionTestRecord) Finalize 

func (_ ComplexUnionTestRecord) Finalize()

func (*ComplexUnionTestRecord) Get 

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

func (ComplexUnionTestRecord) HintSize 

func (_ ComplexUnionTestRecord) HintSize(int)

func (ComplexUnionTestRecord) MarshalJSON 

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

func (*ComplexUnionTestRecord) NullField 

func (r *ComplexUnionTestRecord) NullField(i int)

func (ComplexUnionTestRecord) Schema 

func (r ComplexUnionTestRecord) Schema() string

func (ComplexUnionTestRecord) SchemaName 

func (r ComplexUnionTestRecord) SchemaName() string

func (ComplexUnionTestRecord) Serialize 

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

func (ComplexUnionTestRecord) SetBoolean 

func (_ ComplexUnionTestRecord) SetBoolean(v bool)

func (ComplexUnionTestRecord) SetBytes 

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

func (*ComplexUnionTestRecord) SetDefault 

func (r *ComplexUnionTestRecord) SetDefault(i int)

func (ComplexUnionTestRecord) SetDouble 

func (_ ComplexUnionTestRecord) SetDouble(v float64)

func (ComplexUnionTestRecord) SetFloat 

func (_ ComplexUnionTestRecord) SetFloat(v float32)

func (ComplexUnionTestRecord) SetInt 

func (_ ComplexUnionTestRecord) SetInt(v int32)

func (ComplexUnionTestRecord) SetLong 

func (_ ComplexUnionTestRecord) SetLong(v int64)

func (ComplexUnionTestRecord) SetString 

func (_ ComplexUnionTestRecord) SetString(v string)

func (ComplexUnionTestRecord) SetUnionElem 

func (_ ComplexUnionTestRecord) SetUnionElem(v int64)

func (*ComplexUnionTestRecord) UnmarshalJSON 

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

type ComplexUnionTestRecordReader 

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

container reader

func NewComplexUnionTestRecordReader 

func NewComplexUnionTestRecordReader(r io.Reader) (*ComplexUnionTestRecordReader, error)

func (ComplexUnionTestRecordReader) Read 

func (r ComplexUnionTestRecordReader) Read() (ComplexUnionTestRecord, error)

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 NestedUnionRecord 

type NestedUnionRecord struct {
	IntField int32 `json:"IntField"`
}

func DeserializeNestedUnionRecord 

func DeserializeNestedUnionRecord(r io.Reader) (NestedUnionRecord, error)

func DeserializeNestedUnionRecordFromSchema 

func DeserializeNestedUnionRecordFromSchema(r io.Reader, schema string) (NestedUnionRecord, error)

func NewNestedUnionRecord 

func NewNestedUnionRecord() NestedUnionRecord

func (NestedUnionRecord) AppendArray 

func (_ NestedUnionRecord) AppendArray() types.Field

func (NestedUnionRecord) AppendMap 

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

func (NestedUnionRecord) AvroCRC64Fingerprint 

func (_ NestedUnionRecord) AvroCRC64Fingerprint() []byte

func (NestedUnionRecord) Finalize 

func (_ NestedUnionRecord) Finalize()

func (*NestedUnionRecord) Get 

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

func (NestedUnionRecord) HintSize 

func (_ NestedUnionRecord) HintSize(int)

func (NestedUnionRecord) MarshalJSON 

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

func (*NestedUnionRecord) NullField 

func (r *NestedUnionRecord) NullField(i int)

func (NestedUnionRecord) Schema 

func (r NestedUnionRecord) Schema() string

func (NestedUnionRecord) SchemaName 

func (r NestedUnionRecord) SchemaName() string

func (NestedUnionRecord) Serialize 

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

func (NestedUnionRecord) SetBoolean 

func (_ NestedUnionRecord) SetBoolean(v bool)

func (NestedUnionRecord) SetBytes 

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

func (*NestedUnionRecord) SetDefault 

func (r *NestedUnionRecord) SetDefault(i int)

func (NestedUnionRecord) SetDouble 

func (_ NestedUnionRecord) SetDouble(v float64)

func (NestedUnionRecord) SetFloat 

func (_ NestedUnionRecord) SetFloat(v float32)

func (NestedUnionRecord) SetInt 

func (_ NestedUnionRecord) SetInt(v int32)

func (NestedUnionRecord) SetLong 

func (_ NestedUnionRecord) SetLong(v int64)

func (NestedUnionRecord) SetString 

func (_ NestedUnionRecord) SetString(v string)

func (NestedUnionRecord) SetUnionElem 

func (_ NestedUnionRecord) SetUnionElem(v int64)

func (*NestedUnionRecord) UnmarshalJSON 

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

type NestedUnionRecordReader 

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

container reader

func NewNestedUnionRecordReader 

func NewNestedUnionRecordReader(r io.Reader) (*NestedUnionRecordReader, error)

func (NestedUnionRecordReader) Read 

func (r NestedUnionRecordReader) Read() (NestedUnionRecord, error)

type UnionNullArrayIntMapIntNestedUnionRecord 

type UnionNullArrayIntMapIntNestedUnionRecord struct {
	Null              *types.NullVal
	ArrayInt          []int32
	MapInt            map[string]int32
	NestedUnionRecord NestedUnionRecord
	UnionType         UnionNullArrayIntMapIntNestedUnionRecordTypeEnum
}

func DeserializeUnionNullArrayIntMapIntNestedUnionRecord 

func DeserializeUnionNullArrayIntMapIntNestedUnionRecord(r io.Reader) (*UnionNullArrayIntMapIntNestedUnionRecord, error)

func DeserializeUnionNullArrayIntMapIntNestedUnionRecordFromSchema 

func DeserializeUnionNullArrayIntMapIntNestedUnionRecordFromSchema(r io.Reader, schema string) (*UnionNullArrayIntMapIntNestedUnionRecord, error)

func NewUnionNullArrayIntMapIntNestedUnionRecord 

func NewUnionNullArrayIntMapIntNestedUnionRecord() *UnionNullArrayIntMapIntNestedUnionRecord

func (*UnionNullArrayIntMapIntNestedUnionRecord) AppendArray 

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

func (*UnionNullArrayIntMapIntNestedUnionRecord) AppendMap 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) AppendMap(key string) types.Field

func (*UnionNullArrayIntMapIntNestedUnionRecord) Finalize 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) Finalize()

func (*UnionNullArrayIntMapIntNestedUnionRecord) Get 

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

func (*UnionNullArrayIntMapIntNestedUnionRecord) HintSize 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) HintSize(i int)

func (*UnionNullArrayIntMapIntNestedUnionRecord) MarshalJSON 

func (r *UnionNullArrayIntMapIntNestedUnionRecord) MarshalJSON() ([]byte, error)

func (*UnionNullArrayIntMapIntNestedUnionRecord) NullField 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) NullField(i int)

func (*UnionNullArrayIntMapIntNestedUnionRecord) Schema 

func (r *UnionNullArrayIntMapIntNestedUnionRecord) Schema() string

func (*UnionNullArrayIntMapIntNestedUnionRecord) Serialize 

func (r *UnionNullArrayIntMapIntNestedUnionRecord) Serialize(w io.Writer) error

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetBoolean 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) SetBoolean(v bool)

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetBytes 

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

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetDefault 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) SetDefault(i int)

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetDouble 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) SetDouble(v float64)

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetFloat 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) SetFloat(v float32)

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetInt 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) SetInt(v int32)

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetLong 

func (r *UnionNullArrayIntMapIntNestedUnionRecord) SetLong(v int64)

func (*UnionNullArrayIntMapIntNestedUnionRecord) SetString 

func (_ *UnionNullArrayIntMapIntNestedUnionRecord) SetString(v string)

func (*UnionNullArrayIntMapIntNestedUnionRecord) UnmarshalJSON 

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

type UnionNullArrayIntMapIntNestedUnionRecordTypeEnum 

type UnionNullArrayIntMapIntNestedUnionRecordTypeEnum int
const (
	UnionNullArrayIntMapIntNestedUnionRecordTypeEnumArrayInt UnionNullArrayIntMapIntNestedUnionRecordTypeEnum = 1

	UnionNullArrayIntMapIntNestedUnionRecordTypeEnumMapInt UnionNullArrayIntMapIntNestedUnionRecordTypeEnum = 2

	UnionNullArrayIntMapIntNestedUnionRecordTypeEnumNestedUnionRecord UnionNullArrayIntMapIntNestedUnionRecordTypeEnum = 3
)

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.