avro

package
v10.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2021 License: MIT Imports: 8 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

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 NestedRecordAvroCRC64Fingerprint = "\x81\x8d\xc3K?\xe83\xcc"
View Source 
const NestedTestRecordAvroCRC64Fingerprint = "@8B\xd3\xc9\xf5\xb5\x9b"

Variables

This section is empty.

Functions

func NewNestedRecordWriter 

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

func NewNestedTestRecordWriter 

func NewNestedTestRecordWriter(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) HintSize 

func (b BytesWrapper) HintSize(int)

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 NestedRecord 

type NestedRecord struct {
	StringField string `json:"StringField"`

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

func DeserializeNestedRecord 

func DeserializeNestedRecord(r io.Reader) (NestedRecord, error)

func DeserializeNestedRecordFromSchema 

func DeserializeNestedRecordFromSchema(r io.Reader, schema string) (NestedRecord, error)

func NewNestedRecord 

func NewNestedRecord() NestedRecord

func (NestedRecord) AppendArray 

func (_ NestedRecord) AppendArray() types.Field

func (NestedRecord) AppendMap 

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

func (NestedRecord) AvroCRC64Fingerprint 

func (_ NestedRecord) AvroCRC64Fingerprint() []byte

func (NestedRecord) Finalize 

func (_ NestedRecord) Finalize()

func (*NestedRecord) Get 

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

func (NestedRecord) HintSize 

func (_ NestedRecord) HintSize(int)

func (NestedRecord) MarshalJSON 

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

func (*NestedRecord) NullField 

func (r *NestedRecord) NullField(i int)

func (NestedRecord) Schema 

func (r NestedRecord) Schema() string

func (NestedRecord) SchemaName 

func (r NestedRecord) SchemaName() string

func (NestedRecord) Serialize 

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

func (NestedRecord) SetBoolean 

func (_ NestedRecord) SetBoolean(v bool)

func (NestedRecord) SetBytes 

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

func (*NestedRecord) SetDefault 

func (r *NestedRecord) SetDefault(i int)

func (NestedRecord) SetDouble 

func (_ NestedRecord) SetDouble(v float64)

func (NestedRecord) SetFloat 

func (_ NestedRecord) SetFloat(v float32)

func (NestedRecord) SetInt 

func (_ NestedRecord) SetInt(v int32)

func (NestedRecord) SetLong 

func (_ NestedRecord) SetLong(v int64)

func (NestedRecord) SetString 

func (_ NestedRecord) SetString(v string)

func (NestedRecord) SetUnionElem 

func (_ NestedRecord) SetUnionElem(v int64)

func (*NestedRecord) UnmarshalJSON 

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

type NestedRecordReader 

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

container reader

func NewNestedRecordReader 

func NewNestedRecordReader(r io.Reader) (*NestedRecordReader, error)

func (NestedRecordReader) Read 

func (r NestedRecordReader) Read() (NestedRecord, error)

type NestedTestRecord 

type NestedTestRecord struct {
	OtherField NestedRecord `json:"OtherField"`
}

func DeserializeNestedTestRecord 

func DeserializeNestedTestRecord(r io.Reader) (NestedTestRecord, error)

func DeserializeNestedTestRecordFromSchema 

func DeserializeNestedTestRecordFromSchema(r io.Reader, schema string) (NestedTestRecord, error)

func NewNestedTestRecord 

func NewNestedTestRecord() NestedTestRecord

func (NestedTestRecord) AppendArray 

func (_ NestedTestRecord) AppendArray() types.Field

func (NestedTestRecord) AppendMap 

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

func (NestedTestRecord) AvroCRC64Fingerprint 

func (_ NestedTestRecord) AvroCRC64Fingerprint() []byte

func (NestedTestRecord) Finalize 

func (_ NestedTestRecord) Finalize()

func (*NestedTestRecord) Get 

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

func (NestedTestRecord) HintSize 

func (_ NestedTestRecord) HintSize(int)

func (NestedTestRecord) MarshalJSON 

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

func (*NestedTestRecord) NullField 

func (r *NestedTestRecord) NullField(i int)

func (NestedTestRecord) Schema 

func (r NestedTestRecord) Schema() string

func (NestedTestRecord) SchemaName 

func (r NestedTestRecord) SchemaName() string

func (NestedTestRecord) Serialize 

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

func (NestedTestRecord) SetBoolean 

func (_ NestedTestRecord) SetBoolean(v bool)

func (NestedTestRecord) SetBytes 

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

func (*NestedTestRecord) SetDefault 

func (r *NestedTestRecord) SetDefault(i int)

func (NestedTestRecord) SetDouble 

func (_ NestedTestRecord) SetDouble(v float64)

func (NestedTestRecord) SetFloat 

func (_ NestedTestRecord) SetFloat(v float32)

func (NestedTestRecord) SetInt 

func (_ NestedTestRecord) SetInt(v int32)

func (NestedTestRecord) SetLong 

func (_ NestedTestRecord) SetLong(v int64)

func (NestedTestRecord) SetString 

func (_ NestedTestRecord) SetString(v string)

func (NestedTestRecord) SetUnionElem 

func (_ NestedTestRecord) SetUnionElem(v int64)

func (*NestedTestRecord) UnmarshalJSON 

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

type NestedTestRecordReader 

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

container reader

func NewNestedTestRecordReader 

func NewNestedTestRecordReader(r io.Reader) (*NestedTestRecordReader, error)

func (NestedTestRecordReader) Read 

func (r NestedTestRecordReader) Read() (NestedTestRecord, error)

type UnionNestedRecordNestedTestRecord 

type UnionNestedRecordNestedTestRecord struct {
	NestedRecord     NestedRecord
	NestedTestRecord NestedTestRecord
	UnionType        UnionNestedRecordNestedTestRecordTypeEnum
}

func DeserializeUnionNestedRecordNestedTestRecord 

func DeserializeUnionNestedRecordNestedTestRecord(r io.Reader) (UnionNestedRecordNestedTestRecord, error)

func DeserializeUnionNestedRecordNestedTestRecordFromSchema 

func DeserializeUnionNestedRecordNestedTestRecordFromSchema(r io.Reader, schema string) (UnionNestedRecordNestedTestRecord, error)

func NewUnionNestedRecordNestedTestRecord 

func NewUnionNestedRecordNestedTestRecord() UnionNestedRecordNestedTestRecord

func (UnionNestedRecordNestedTestRecord) AppendArray 

func (_ UnionNestedRecordNestedTestRecord) AppendArray() types.Field

func (UnionNestedRecordNestedTestRecord) AppendMap 

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

func (UnionNestedRecordNestedTestRecord) Finalize 

func (_ UnionNestedRecordNestedTestRecord) Finalize()

func (*UnionNestedRecordNestedTestRecord) Get 

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

func (UnionNestedRecordNestedTestRecord) HintSize 

func (_ UnionNestedRecordNestedTestRecord) HintSize(i int)

func (UnionNestedRecordNestedTestRecord) MarshalJSON 

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

func (UnionNestedRecordNestedTestRecord) NullField 

func (_ UnionNestedRecordNestedTestRecord) NullField(i int)

func (UnionNestedRecordNestedTestRecord) Schema 

func (r UnionNestedRecordNestedTestRecord) Schema() string

func (UnionNestedRecordNestedTestRecord) Serialize 

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

func (UnionNestedRecordNestedTestRecord) SetBoolean 

func (_ UnionNestedRecordNestedTestRecord) SetBoolean(v bool)

func (UnionNestedRecordNestedTestRecord) SetBytes 

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

func (UnionNestedRecordNestedTestRecord) SetDefault 

func (_ UnionNestedRecordNestedTestRecord) SetDefault(i int)

func (UnionNestedRecordNestedTestRecord) SetDouble 

func (_ UnionNestedRecordNestedTestRecord) SetDouble(v float64)

func (UnionNestedRecordNestedTestRecord) SetFloat 

func (_ UnionNestedRecordNestedTestRecord) SetFloat(v float32)

func (UnionNestedRecordNestedTestRecord) SetInt 

func (_ UnionNestedRecordNestedTestRecord) SetInt(v int32)

func (*UnionNestedRecordNestedTestRecord) SetLong 

func (r *UnionNestedRecordNestedTestRecord) SetLong(v int64)

func (UnionNestedRecordNestedTestRecord) SetString 

func (_ UnionNestedRecordNestedTestRecord) SetString(v string)

func (*UnionNestedRecordNestedTestRecord) UnmarshalJSON 

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

type UnionNestedRecordNestedTestRecordTypeEnum 

type UnionNestedRecordNestedTestRecordTypeEnum int
const (
	UnionNestedRecordNestedTestRecordTypeEnumNestedRecord UnionNestedRecordNestedTestRecordTypeEnum = 0

	UnionNestedRecordNestedTestRecordTypeEnumNestedTestRecord UnionNestedRecordNestedTestRecordTypeEnum = 1
)

Source Files

View all Source files

Directories

Path Synopsis
Code generated by github.com/actgardner/gogen-avro/v10.
 Code generated by github.com/actgardner/gogen-avro/v10.

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.