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:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

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

  • SOURCE:
  • evolution.avsc

Index

Constants

View Source 
const UnionRecAvroCRC64Fingerprint = "1\xf9\xae\xb7W\x80#\xf9"
View Source 
const UnionRecordAvroCRC64Fingerprint = "q\x867|8\xab\u070f"

Variables

This section is empty.

Functions

func NewUnionRecWriter 

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

func NewUnionRecordWriter 

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

Types

type UnionNullString 

type UnionNullString struct {
	Null      *types.NullVal
	String    string
	UnionType UnionNullStringTypeEnum
}

func DeserializeUnionNullString 

func DeserializeUnionNullString(r io.Reader) (*UnionNullString, error)

func DeserializeUnionNullStringFromSchema 

func DeserializeUnionNullStringFromSchema(r io.Reader, schema string) (*UnionNullString, error)

func NewUnionNullString 

func NewUnionNullString() *UnionNullString

func (*UnionNullString) AppendArray 

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

func (*UnionNullString) AppendMap 

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

func (*UnionNullString) Finalize 

func (_ *UnionNullString) Finalize()

func (*UnionNullString) Get 

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

func (*UnionNullString) MarshalJSON 

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

func (*UnionNullString) NullField 

func (_ *UnionNullString) NullField(i int)

func (*UnionNullString) Schema 

func (r *UnionNullString) Schema() string

func (*UnionNullString) Serialize 

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

func (*UnionNullString) SetBoolean 

func (_ *UnionNullString) SetBoolean(v bool)

func (*UnionNullString) SetBytes 

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

func (*UnionNullString) SetDefault 

func (_ *UnionNullString) SetDefault(i int)

func (*UnionNullString) SetDouble 

func (_ *UnionNullString) SetDouble(v float64)

func (*UnionNullString) SetFloat 

func (_ *UnionNullString) SetFloat(v float32)

func (*UnionNullString) SetInt 

func (_ *UnionNullString) SetInt(v int32)

func (*UnionNullString) SetLong 

func (r *UnionNullString) SetLong(v int64)

func (*UnionNullString) SetString 

func (_ *UnionNullString) SetString(v string)

func (*UnionNullString) UnmarshalJSON 

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

type UnionNullStringTypeEnum 

type UnionNullStringTypeEnum int
const (
	UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)

type UnionRec 

type UnionRec struct {
	A int32 `json:"a"`
}

func DeserializeUnionRec 

func DeserializeUnionRec(r io.Reader) (UnionRec, error)

func DeserializeUnionRecFromSchema 

func DeserializeUnionRecFromSchema(r io.Reader, schema string) (UnionRec, error)

func NewUnionRec 

func NewUnionRec() UnionRec

func (UnionRec) AppendArray 

func (_ UnionRec) AppendArray() types.Field

func (UnionRec) AppendMap 

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

func (UnionRec) AvroCRC64Fingerprint 

func (_ UnionRec) AvroCRC64Fingerprint() []byte

func (UnionRec) Finalize 

func (_ UnionRec) Finalize()

func (*UnionRec) Get 

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

func (UnionRec) MarshalJSON 

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

func (*UnionRec) NullField 

func (r *UnionRec) NullField(i int)

func (UnionRec) Schema 

func (r UnionRec) Schema() string

func (UnionRec) SchemaName 

func (r UnionRec) SchemaName() string

func (UnionRec) Serialize 

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

func (UnionRec) SetBoolean 

func (_ UnionRec) SetBoolean(v bool)

func (UnionRec) SetBytes 

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

func (*UnionRec) SetDefault 

func (r *UnionRec) SetDefault(i int)

func (UnionRec) SetDouble 

func (_ UnionRec) SetDouble(v float64)

func (UnionRec) SetFloat 

func (_ UnionRec) SetFloat(v float32)

func (UnionRec) SetInt 

func (_ UnionRec) SetInt(v int32)

func (UnionRec) SetLong 

func (_ UnionRec) SetLong(v int64)

func (UnionRec) SetString 

func (_ UnionRec) SetString(v string)

func (UnionRec) SetUnionElem 

func (_ UnionRec) SetUnionElem(v int64)

func (*UnionRec) UnmarshalJSON 

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

type UnionRecReader 

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

container reader

func NewUnionRecReader 

func NewUnionRecReader(r io.Reader) (*UnionRecReader, error)

func (UnionRecReader) Read 

func (r UnionRecReader) Read() (UnionRec, error)

type UnionRecord 

type UnionRecord struct {
	Id string `json:"id"`

	UnionNull *UnionString `json:"unionNull"`

	UnionString UnionStringInt `json:"unionString"`

	UnionRecord UnionUnionRecString `json:"unionRecord"`
}

func DeserializeUnionRecord 

func DeserializeUnionRecord(r io.Reader) (UnionRecord, error)

func DeserializeUnionRecordFromSchema 

func DeserializeUnionRecordFromSchema(r io.Reader, schema string) (UnionRecord, error)

func NewUnionRecord 

func NewUnionRecord() UnionRecord

func (UnionRecord) AppendArray 

func (_ UnionRecord) AppendArray() types.Field

func (UnionRecord) AppendMap 

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

func (UnionRecord) AvroCRC64Fingerprint 

func (_ UnionRecord) AvroCRC64Fingerprint() []byte

func (UnionRecord) Finalize 

func (_ UnionRecord) Finalize()

func (*UnionRecord) Get 

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

func (UnionRecord) MarshalJSON 

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

func (*UnionRecord) NullField 

func (r *UnionRecord) NullField(i int)

func (UnionRecord) Schema 

func (r UnionRecord) Schema() string

func (UnionRecord) SchemaName 

func (r UnionRecord) SchemaName() string

func (UnionRecord) Serialize 

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

func (UnionRecord) SetBoolean 

func (_ UnionRecord) SetBoolean(v bool)

func (UnionRecord) SetBytes 

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

func (*UnionRecord) SetDefault 

func (r *UnionRecord) SetDefault(i int)

func (UnionRecord) SetDouble 

func (_ UnionRecord) SetDouble(v float64)

func (UnionRecord) SetFloat 

func (_ UnionRecord) SetFloat(v float32)

func (UnionRecord) SetInt 

func (_ UnionRecord) SetInt(v int32)

func (UnionRecord) SetLong 

func (_ UnionRecord) SetLong(v int64)

func (UnionRecord) SetString 

func (_ UnionRecord) SetString(v string)

func (UnionRecord) SetUnionElem 

func (_ UnionRecord) SetUnionElem(v int64)

func (*UnionRecord) UnmarshalJSON 

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

type UnionRecordReader 

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

container reader

func NewUnionRecordReader 

func NewUnionRecordReader(r io.Reader) (*UnionRecordReader, error)

func (UnionRecordReader) Read 

func (r UnionRecordReader) Read() (UnionRecord, error)

type UnionString 

type UnionString struct {
	Null      *types.NullVal
	String    string
	UnionType UnionStringTypeEnum
}

func DeserializeUnionString 

func DeserializeUnionString(r io.Reader) (*UnionString, error)

func DeserializeUnionStringFromSchema 

func DeserializeUnionStringFromSchema(r io.Reader, schema string) (*UnionString, error)

func NewUnionString 

func NewUnionString() *UnionString

func (*UnionString) AppendArray 

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

func (*UnionString) AppendMap 

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

func (*UnionString) Finalize 

func (_ *UnionString) Finalize()

func (*UnionString) Get 

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

func (*UnionString) MarshalJSON 

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

func (*UnionString) NullField 

func (_ *UnionString) NullField(i int)

func (*UnionString) Schema 

func (r *UnionString) Schema() string

func (*UnionString) Serialize 

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

func (*UnionString) SetBoolean 

func (_ *UnionString) SetBoolean(v bool)

func (*UnionString) SetBytes 

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

func (*UnionString) SetDefault 

func (_ *UnionString) SetDefault(i int)

func (*UnionString) SetDouble 

func (_ *UnionString) SetDouble(v float64)

func (*UnionString) SetFloat 

func (_ *UnionString) SetFloat(v float32)

func (*UnionString) SetInt 

func (_ *UnionString) SetInt(v int32)

func (*UnionString) SetLong 

func (r *UnionString) SetLong(v int64)

func (*UnionString) SetString 

func (_ *UnionString) SetString(v string)

func (*UnionString) UnmarshalJSON 

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

type UnionStringInt 

type UnionStringInt struct {
	String    string
	Int       int32
	UnionType UnionStringIntTypeEnum
}

func DeserializeUnionStringInt 

func DeserializeUnionStringInt(r io.Reader) (UnionStringInt, error)

func DeserializeUnionStringIntFromSchema 

func DeserializeUnionStringIntFromSchema(r io.Reader, schema string) (UnionStringInt, error)

func NewUnionStringInt 

func NewUnionStringInt() UnionStringInt

func (UnionStringInt) AppendArray 

func (_ UnionStringInt) AppendArray() types.Field

func (UnionStringInt) AppendMap 

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

func (UnionStringInt) Finalize 

func (_ UnionStringInt) Finalize()

func (*UnionStringInt) Get 

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

func (UnionStringInt) MarshalJSON 

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

func (UnionStringInt) NullField 

func (_ UnionStringInt) NullField(i int)

func (UnionStringInt) Schema 

func (r UnionStringInt) Schema() string

func (UnionStringInt) Serialize 

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

func (UnionStringInt) SetBoolean 

func (_ UnionStringInt) SetBoolean(v bool)

func (UnionStringInt) SetBytes 

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

func (UnionStringInt) SetDefault 

func (_ UnionStringInt) SetDefault(i int)

func (UnionStringInt) SetDouble 

func (_ UnionStringInt) SetDouble(v float64)

func (UnionStringInt) SetFloat 

func (_ UnionStringInt) SetFloat(v float32)

func (UnionStringInt) SetInt 

func (_ UnionStringInt) SetInt(v int32)

func (*UnionStringInt) SetLong 

func (r *UnionStringInt) SetLong(v int64)

func (UnionStringInt) SetString 

func (_ UnionStringInt) SetString(v string)

func (*UnionStringInt) UnmarshalJSON 

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

type UnionStringIntTypeEnum 

type UnionStringIntTypeEnum int
const (
	UnionStringIntTypeEnumString UnionStringIntTypeEnum = 0

	UnionStringIntTypeEnumInt UnionStringIntTypeEnum = 1
)

type UnionStringTypeEnum 

type UnionStringTypeEnum int
const (
	UnionStringTypeEnumString UnionStringTypeEnum = 1
)

type UnionUnionRecString 

type UnionUnionRecString struct {
	UnionRec  UnionRec
	String    string
	UnionType UnionUnionRecStringTypeEnum
}

func DeserializeUnionUnionRecString 

func DeserializeUnionUnionRecString(r io.Reader) (UnionUnionRecString, error)

func DeserializeUnionUnionRecStringFromSchema 

func DeserializeUnionUnionRecStringFromSchema(r io.Reader, schema string) (UnionUnionRecString, error)

func NewUnionUnionRecString 

func NewUnionUnionRecString() UnionUnionRecString

func (UnionUnionRecString) AppendArray 

func (_ UnionUnionRecString) AppendArray() types.Field

func (UnionUnionRecString) AppendMap 

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

func (UnionUnionRecString) Finalize 

func (_ UnionUnionRecString) Finalize()

func (*UnionUnionRecString) Get 

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

func (UnionUnionRecString) MarshalJSON 

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

func (UnionUnionRecString) NullField 

func (_ UnionUnionRecString) NullField(i int)

func (UnionUnionRecString) Schema 

func (r UnionUnionRecString) Schema() string

func (UnionUnionRecString) Serialize 

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

func (UnionUnionRecString) SetBoolean 

func (_ UnionUnionRecString) SetBoolean(v bool)

func (UnionUnionRecString) SetBytes 

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

func (UnionUnionRecString) SetDefault 

func (_ UnionUnionRecString) SetDefault(i int)

func (UnionUnionRecString) SetDouble 

func (_ UnionUnionRecString) SetDouble(v float64)

func (UnionUnionRecString) SetFloat 

func (_ UnionUnionRecString) SetFloat(v float32)

func (UnionUnionRecString) SetInt 

func (_ UnionUnionRecString) SetInt(v int32)

func (*UnionUnionRecString) SetLong 

func (r *UnionUnionRecString) SetLong(v int64)

func (UnionUnionRecString) SetString 

func (_ UnionUnionRecString) SetString(v string)

func (*UnionUnionRecString) UnmarshalJSON 

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

type UnionUnionRecStringTypeEnum 

type UnionUnionRecStringTypeEnum int
const (
	UnionUnionRecStringTypeEnumUnionRec UnionUnionRecStringTypeEnum = 0

	UnionUnionRecStringTypeEnumString UnionUnionRecStringTypeEnum = 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.