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: 8 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

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

  • SOURCE:
  • schema.avsc

Index

Constants

View Source 
const PrimitiveUnionTestRecordAvroCRC64Fingerprint = "N\xf1pp\x85\x9d\xed="
View Source 
const Record1AvroCRC64Fingerprint = "5\x1f\v\x05O7Z\x02"
View Source 
const Record2AvroCRC64Fingerprint = "S\n_\xab\xc7-\xf9\x9c"

Variables

This section is empty.

Functions

func NewPrimitiveUnionTestRecordWriter 

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

func NewRecord1Writer 

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

func NewRecord2Writer 

func NewRecord2Writer(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) 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 PrimitiveUnionTestRecord 

type PrimitiveUnionTestRecord struct {
	UnionField UnionBytesStringRecord1Record2 `json:"UnionField"`
}

func DeserializePrimitiveUnionTestRecord 

func DeserializePrimitiveUnionTestRecord(r io.Reader) (PrimitiveUnionTestRecord, error)

func DeserializePrimitiveUnionTestRecordFromSchema 

func DeserializePrimitiveUnionTestRecordFromSchema(r io.Reader, schema string) (PrimitiveUnionTestRecord, error)

func NewPrimitiveUnionTestRecord 

func NewPrimitiveUnionTestRecord() PrimitiveUnionTestRecord

func (PrimitiveUnionTestRecord) AppendArray 

func (_ PrimitiveUnionTestRecord) AppendArray() types.Field

func (PrimitiveUnionTestRecord) AppendMap 

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

func (PrimitiveUnionTestRecord) AvroCRC64Fingerprint 

func (_ PrimitiveUnionTestRecord) AvroCRC64Fingerprint() []byte

func (PrimitiveUnionTestRecord) Finalize 

func (_ PrimitiveUnionTestRecord) Finalize()

func (*PrimitiveUnionTestRecord) Get 

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

func (PrimitiveUnionTestRecord) MarshalJSON 

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

func (*PrimitiveUnionTestRecord) NullField 

func (r *PrimitiveUnionTestRecord) NullField(i int)

func (PrimitiveUnionTestRecord) Schema 

func (r PrimitiveUnionTestRecord) Schema() string

func (PrimitiveUnionTestRecord) SchemaName 

func (r PrimitiveUnionTestRecord) SchemaName() string

func (PrimitiveUnionTestRecord) Serialize 

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

func (PrimitiveUnionTestRecord) SetBoolean 

func (_ PrimitiveUnionTestRecord) SetBoolean(v bool)

func (PrimitiveUnionTestRecord) SetBytes 

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

func (*PrimitiveUnionTestRecord) SetDefault 

func (r *PrimitiveUnionTestRecord) SetDefault(i int)

func (PrimitiveUnionTestRecord) SetDouble 

func (_ PrimitiveUnionTestRecord) SetDouble(v float64)

func (PrimitiveUnionTestRecord) SetFloat 

func (_ PrimitiveUnionTestRecord) SetFloat(v float32)

func (PrimitiveUnionTestRecord) SetInt 

func (_ PrimitiveUnionTestRecord) SetInt(v int32)

func (PrimitiveUnionTestRecord) SetLong 

func (_ PrimitiveUnionTestRecord) SetLong(v int64)

func (PrimitiveUnionTestRecord) SetString 

func (_ PrimitiveUnionTestRecord) SetString(v string)

func (PrimitiveUnionTestRecord) SetUnionElem 

func (_ PrimitiveUnionTestRecord) SetUnionElem(v int64)

func (*PrimitiveUnionTestRecord) UnmarshalJSON 

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

type PrimitiveUnionTestRecordReader 

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

container reader

func NewPrimitiveUnionTestRecordReader 

func NewPrimitiveUnionTestRecordReader(r io.Reader) (*PrimitiveUnionTestRecordReader, error)

func (PrimitiveUnionTestRecordReader) Read 

func (r PrimitiveUnionTestRecordReader) Read() (PrimitiveUnionTestRecord, error)

type Record1 

type Record1 struct {
	Intfield int32 `json:"intfield"`
}

func DeserializeRecord1 

func DeserializeRecord1(r io.Reader) (Record1, error)

func DeserializeRecord1FromSchema 

func DeserializeRecord1FromSchema(r io.Reader, schema string) (Record1, error)

func NewRecord1 

func NewRecord1() Record1

func (Record1) AppendArray 

func (_ Record1) AppendArray() types.Field

func (Record1) AppendMap 

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

func (Record1) AvroCRC64Fingerprint 

func (_ Record1) AvroCRC64Fingerprint() []byte

func (Record1) Finalize 

func (_ Record1) Finalize()

func (*Record1) Get 

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

func (Record1) MarshalJSON 

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

func (*Record1) NullField 

func (r *Record1) NullField(i int)

func (Record1) Schema 

func (r Record1) Schema() string

func (Record1) SchemaName 

func (r Record1) SchemaName() string

func (Record1) Serialize 

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

func (Record1) SetBoolean 

func (_ Record1) SetBoolean(v bool)

func (Record1) SetBytes 

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

func (*Record1) SetDefault 

func (r *Record1) SetDefault(i int)

func (Record1) SetDouble 

func (_ Record1) SetDouble(v float64)

func (Record1) SetFloat 

func (_ Record1) SetFloat(v float32)

func (Record1) SetInt 

func (_ Record1) SetInt(v int32)

func (Record1) SetLong 

func (_ Record1) SetLong(v int64)

func (Record1) SetString 

func (_ Record1) SetString(v string)

func (Record1) SetUnionElem 

func (_ Record1) SetUnionElem(v int64)

func (*Record1) UnmarshalJSON 

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

type Record1Reader 

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

container reader

func NewRecord1Reader 

func NewRecord1Reader(r io.Reader) (*Record1Reader, error)

func (Record1Reader) Read 

func (r Record1Reader) Read() (Record1, error)

type Record2 

type Record2 struct {
	Intfield int32 `json:"intfield"`
}

func DeserializeRecord2 

func DeserializeRecord2(r io.Reader) (Record2, error)

func DeserializeRecord2FromSchema 

func DeserializeRecord2FromSchema(r io.Reader, schema string) (Record2, error)

func NewRecord2 

func NewRecord2() Record2

func (Record2) AppendArray 

func (_ Record2) AppendArray() types.Field

func (Record2) AppendMap 

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

func (Record2) AvroCRC64Fingerprint 

func (_ Record2) AvroCRC64Fingerprint() []byte

func (Record2) Finalize 

func (_ Record2) Finalize()

func (*Record2) Get 

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

func (Record2) MarshalJSON 

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

func (*Record2) NullField 

func (r *Record2) NullField(i int)

func (Record2) Schema 

func (r Record2) Schema() string

func (Record2) SchemaName 

func (r Record2) SchemaName() string

func (Record2) Serialize 

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

func (Record2) SetBoolean 

func (_ Record2) SetBoolean(v bool)

func (Record2) SetBytes 

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

func (*Record2) SetDefault 

func (r *Record2) SetDefault(i int)

func (Record2) SetDouble 

func (_ Record2) SetDouble(v float64)

func (Record2) SetFloat 

func (_ Record2) SetFloat(v float32)

func (Record2) SetInt 

func (_ Record2) SetInt(v int32)

func (Record2) SetLong 

func (_ Record2) SetLong(v int64)

func (Record2) SetString 

func (_ Record2) SetString(v string)

func (Record2) SetUnionElem 

func (_ Record2) SetUnionElem(v int64)

func (*Record2) UnmarshalJSON 

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

type Record2Reader 

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

container reader

func NewRecord2Reader 

func NewRecord2Reader(r io.Reader) (*Record2Reader, error)

func (Record2Reader) Read 

func (r Record2Reader) Read() (Record2, error)

type UnionBytesStringRecord1Record2 

type UnionBytesStringRecord1Record2 struct {
	Bytes     Bytes
	String    string
	Record1   Record1
	Record2   Record2
	UnionType UnionBytesStringRecord1Record2TypeEnum
}

func DeserializeUnionBytesStringRecord1Record2 

func DeserializeUnionBytesStringRecord1Record2(r io.Reader) (UnionBytesStringRecord1Record2, error)

func DeserializeUnionBytesStringRecord1Record2FromSchema 

func DeserializeUnionBytesStringRecord1Record2FromSchema(r io.Reader, schema string) (UnionBytesStringRecord1Record2, error)

func NewUnionBytesStringRecord1Record2 

func NewUnionBytesStringRecord1Record2() UnionBytesStringRecord1Record2

func (UnionBytesStringRecord1Record2) AppendArray 

func (_ UnionBytesStringRecord1Record2) AppendArray() types.Field

func (UnionBytesStringRecord1Record2) AppendMap 

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

func (UnionBytesStringRecord1Record2) Finalize 

func (_ UnionBytesStringRecord1Record2) Finalize()

func (*UnionBytesStringRecord1Record2) Get 

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

func (UnionBytesStringRecord1Record2) MarshalJSON 

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

func (UnionBytesStringRecord1Record2) NullField 

func (_ UnionBytesStringRecord1Record2) NullField(i int)

func (UnionBytesStringRecord1Record2) Schema 

func (r UnionBytesStringRecord1Record2) Schema() string

func (UnionBytesStringRecord1Record2) Serialize 

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

func (UnionBytesStringRecord1Record2) SetBoolean 

func (_ UnionBytesStringRecord1Record2) SetBoolean(v bool)

func (UnionBytesStringRecord1Record2) SetBytes 

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

func (UnionBytesStringRecord1Record2) SetDefault 

func (_ UnionBytesStringRecord1Record2) SetDefault(i int)

func (UnionBytesStringRecord1Record2) SetDouble 

func (_ UnionBytesStringRecord1Record2) SetDouble(v float64)

func (UnionBytesStringRecord1Record2) SetFloat 

func (_ UnionBytesStringRecord1Record2) SetFloat(v float32)

func (UnionBytesStringRecord1Record2) SetInt 

func (_ UnionBytesStringRecord1Record2) SetInt(v int32)

func (*UnionBytesStringRecord1Record2) SetLong 

func (r *UnionBytesStringRecord1Record2) SetLong(v int64)

func (UnionBytesStringRecord1Record2) SetString 

func (_ UnionBytesStringRecord1Record2) SetString(v string)

func (*UnionBytesStringRecord1Record2) UnmarshalJSON 

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

type UnionBytesStringRecord1Record2TypeEnum 

type UnionBytesStringRecord1Record2TypeEnum int
const (
	UnionBytesStringRecord1Record2TypeEnumBytes UnionBytesStringRecord1Record2TypeEnum = 0

	UnionBytesStringRecord1Record2TypeEnumString UnionBytesStringRecord1Record2TypeEnum = 1

	UnionBytesStringRecord1Record2TypeEnumRecord1 UnionBytesStringRecord1Record2TypeEnum = 2

	UnionBytesStringRecord1Record2TypeEnumRecord2 UnionBytesStringRecord1Record2TypeEnum = 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.