avro

package
v8.0.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. 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) 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 *UnionArrayIntMapIntNestedUnionRecord `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) 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) 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) 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 UnionArrayIntMapIntNestedUnionRecord 

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

func DeserializeUnionArrayIntMapIntNestedUnionRecord 

func DeserializeUnionArrayIntMapIntNestedUnionRecord(r io.Reader) (*UnionArrayIntMapIntNestedUnionRecord, error)

func DeserializeUnionArrayIntMapIntNestedUnionRecordFromSchema 

func DeserializeUnionArrayIntMapIntNestedUnionRecordFromSchema(r io.Reader, schema string) (*UnionArrayIntMapIntNestedUnionRecord, error)

func NewUnionArrayIntMapIntNestedUnionRecord 

func NewUnionArrayIntMapIntNestedUnionRecord() *UnionArrayIntMapIntNestedUnionRecord

func (*UnionArrayIntMapIntNestedUnionRecord) AppendArray 

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

func (*UnionArrayIntMapIntNestedUnionRecord) AppendMap 

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

func (*UnionArrayIntMapIntNestedUnionRecord) Finalize 

func (_ *UnionArrayIntMapIntNestedUnionRecord) Finalize()

func (*UnionArrayIntMapIntNestedUnionRecord) Get 

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

func (*UnionArrayIntMapIntNestedUnionRecord) MarshalJSON 

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

func (*UnionArrayIntMapIntNestedUnionRecord) NullField 

func (_ *UnionArrayIntMapIntNestedUnionRecord) NullField(i int)

func (*UnionArrayIntMapIntNestedUnionRecord) Schema 

func (r *UnionArrayIntMapIntNestedUnionRecord) Schema() string

func (*UnionArrayIntMapIntNestedUnionRecord) Serialize 

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

func (*UnionArrayIntMapIntNestedUnionRecord) SetBoolean 

func (_ *UnionArrayIntMapIntNestedUnionRecord) SetBoolean(v bool)

func (*UnionArrayIntMapIntNestedUnionRecord) SetBytes 

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

func (*UnionArrayIntMapIntNestedUnionRecord) SetDefault 

func (_ *UnionArrayIntMapIntNestedUnionRecord) SetDefault(i int)

func (*UnionArrayIntMapIntNestedUnionRecord) SetDouble 

func (_ *UnionArrayIntMapIntNestedUnionRecord) SetDouble(v float64)

func (*UnionArrayIntMapIntNestedUnionRecord) SetFloat 

func (_ *UnionArrayIntMapIntNestedUnionRecord) SetFloat(v float32)

func (*UnionArrayIntMapIntNestedUnionRecord) SetInt 

func (_ *UnionArrayIntMapIntNestedUnionRecord) SetInt(v int32)

func (*UnionArrayIntMapIntNestedUnionRecord) SetLong 

func (r *UnionArrayIntMapIntNestedUnionRecord) SetLong(v int64)

func (*UnionArrayIntMapIntNestedUnionRecord) SetString 

func (_ *UnionArrayIntMapIntNestedUnionRecord) SetString(v string)

func (*UnionArrayIntMapIntNestedUnionRecord) UnmarshalJSON 

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

type UnionArrayIntMapIntNestedUnionRecordTypeEnum 

type UnionArrayIntMapIntNestedUnionRecordTypeEnum int
const (
	UnionArrayIntMapIntNestedUnionRecordTypeEnumArrayInt UnionArrayIntMapIntNestedUnionRecordTypeEnum = 1

	UnionArrayIntMapIntNestedUnionRecordTypeEnumMapInt UnionArrayIntMapIntNestedUnionRecordTypeEnum = 2

	UnionArrayIntMapIntNestedUnionRecordTypeEnumNestedUnionRecord UnionArrayIntMapIntNestedUnionRecordTypeEnum = 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.