avro

package
v10.2.1 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

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

  • SOURCE:
  • schema.avsc

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

  • SOURCE:
  • schema.avsc

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

  • SOURCE:
  • schema.avsc

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

  • SOURCE:
  • schema.avsc

Index

Constants

View Source 
const MapTestRecordAvroCRC64Fingerprint = "\xf7\xdb\x00\xb2n\xa8u\xbf"

Variables

This section is empty.

Functions

func NewMapTestRecordWriter 

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

Types

type MapTestRecord 

type MapTestRecord struct {
	IntField map[string]*UnionNullInt `json:"IntField"`
}

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)

type MapUnionNullIntWrapper 

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

func (*MapUnionNullIntWrapper) AppendArray 

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

func (*MapUnionNullIntWrapper) AppendMap 

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

func (*MapUnionNullIntWrapper) Finalize 

func (r *MapUnionNullIntWrapper) Finalize()

func (*MapUnionNullIntWrapper) Get 

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

func (*MapUnionNullIntWrapper) HintSize 

func (r *MapUnionNullIntWrapper) HintSize(s int)

func (*MapUnionNullIntWrapper) NullField 

func (r *MapUnionNullIntWrapper) NullField(_ int)

func (*MapUnionNullIntWrapper) SetBoolean 

func (_ *MapUnionNullIntWrapper) SetBoolean(v bool)

func (*MapUnionNullIntWrapper) SetBytes 

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

func (*MapUnionNullIntWrapper) SetDefault 

func (_ *MapUnionNullIntWrapper) SetDefault(i int)

func (*MapUnionNullIntWrapper) SetDouble 

func (_ *MapUnionNullIntWrapper) SetDouble(v float64)

func (*MapUnionNullIntWrapper) SetFloat 

func (_ *MapUnionNullIntWrapper) SetFloat(v float32)

func (*MapUnionNullIntWrapper) SetInt 

func (_ *MapUnionNullIntWrapper) SetInt(v int32)

func (*MapUnionNullIntWrapper) SetLong 

func (_ *MapUnionNullIntWrapper) SetLong(v int64)

func (*MapUnionNullIntWrapper) SetString 

func (_ *MapUnionNullIntWrapper) SetString(v string)

func (*MapUnionNullIntWrapper) SetUnionElem 

func (_ *MapUnionNullIntWrapper) SetUnionElem(v int64)

type UnionNullInt 

type UnionNullInt struct {
	Null      *types.NullVal
	Int       int32
	UnionType UnionNullIntTypeEnum
}

func DeserializeUnionNullInt 

func DeserializeUnionNullInt(r io.Reader) (*UnionNullInt, error)

func DeserializeUnionNullIntFromSchema 

func DeserializeUnionNullIntFromSchema(r io.Reader, schema string) (*UnionNullInt, error)

func NewUnionNullInt 

func NewUnionNullInt() *UnionNullInt

func (*UnionNullInt) AppendArray 

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

func (*UnionNullInt) AppendMap 

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

func (*UnionNullInt) Finalize 

func (_ *UnionNullInt) Finalize()

func (*UnionNullInt) Get 

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

func (*UnionNullInt) HintSize 

func (_ *UnionNullInt) HintSize(i int)

func (*UnionNullInt) MarshalJSON 

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

func (*UnionNullInt) NullField 

func (_ *UnionNullInt) NullField(i int)

func (*UnionNullInt) Schema 

func (r *UnionNullInt) Schema() string

func (*UnionNullInt) Serialize 

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

func (*UnionNullInt) SetBoolean 

func (_ *UnionNullInt) SetBoolean(v bool)

func (*UnionNullInt) SetBytes 

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

func (*UnionNullInt) SetDefault 

func (_ *UnionNullInt) SetDefault(i int)

func (*UnionNullInt) SetDouble 

func (_ *UnionNullInt) SetDouble(v float64)

func (*UnionNullInt) SetFloat 

func (_ *UnionNullInt) SetFloat(v float32)

func (*UnionNullInt) SetInt 

func (_ *UnionNullInt) SetInt(v int32)

func (*UnionNullInt) SetLong 

func (r *UnionNullInt) SetLong(v int64)

func (*UnionNullInt) SetString 

func (_ *UnionNullInt) SetString(v string)

func (*UnionNullInt) UnmarshalJSON 

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

type UnionNullIntTypeEnum 

type UnionNullIntTypeEnum int
const (
	UnionNullIntTypeEnumInt UnionNullIntTypeEnum = 1
)

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.