avro

package
v10.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • evolution.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • evolution.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • evolution.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • evolution.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • evolution.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • evolution.avsc

Index

Constants

View Source 
const AliasedRecordAvroCRC64Fingerprint = "\x95\xd965\xeb$\xa8\x19"
View Source 
const NestedTestRecordAvroCRC64Fingerprint = "\x88\x1a\x80Q&\xb1\x16g"

Variables

This section is empty.

Functions

func NewAliasedRecordWriter 

func NewAliasedRecordWriter(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 AliasedRecord 

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

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

func DeserializeAliasedRecord 

func DeserializeAliasedRecord(r io.Reader) (AliasedRecord, error)

func DeserializeAliasedRecordFromSchema 

func DeserializeAliasedRecordFromSchema(r io.Reader, schema string) (AliasedRecord, error)

func NewAliasedRecord 

func NewAliasedRecord() AliasedRecord

func (AliasedRecord) AppendArray 

func (_ AliasedRecord) AppendArray() types.Field

func (AliasedRecord) AppendMap 

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

func (AliasedRecord) AvroCRC64Fingerprint 

func (_ AliasedRecord) AvroCRC64Fingerprint() []byte

func (AliasedRecord) Finalize 

func (_ AliasedRecord) Finalize()

func (*AliasedRecord) Get 

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

func (AliasedRecord) HintSize 

func (_ AliasedRecord) HintSize(int)

func (AliasedRecord) MarshalJSON 

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

func (*AliasedRecord) NullField 

func (r *AliasedRecord) NullField(i int)

func (AliasedRecord) Schema 

func (r AliasedRecord) Schema() string

func (AliasedRecord) SchemaName 

func (r AliasedRecord) SchemaName() string

func (AliasedRecord) Serialize 

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

func (AliasedRecord) SetBoolean 

func (_ AliasedRecord) SetBoolean(v bool)

func (AliasedRecord) SetBytes 

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

func (*AliasedRecord) SetDefault 

func (r *AliasedRecord) SetDefault(i int)

func (AliasedRecord) SetDouble 

func (_ AliasedRecord) SetDouble(v float64)

func (AliasedRecord) SetFloat 

func (_ AliasedRecord) SetFloat(v float32)

func (AliasedRecord) SetInt 

func (_ AliasedRecord) SetInt(v int32)

func (AliasedRecord) SetLong 

func (_ AliasedRecord) SetLong(v int64)

func (AliasedRecord) SetString 

func (_ AliasedRecord) SetString(v string)

func (AliasedRecord) SetUnionElem 

func (_ AliasedRecord) SetUnionElem(v int64)

func (*AliasedRecord) UnmarshalJSON 

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

type AliasedRecordReader 

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

container reader

func NewAliasedRecordReader 

func NewAliasedRecordReader(r io.Reader) (*AliasedRecordReader, error)

func (AliasedRecordReader) Read 

func (r AliasedRecordReader) Read() (AliasedRecord, error)

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 NestedTestRecord 

type NestedTestRecord struct {
	OtherField AliasedRecord `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 UnionAliasedRecordNestedTestRecord 

type UnionAliasedRecordNestedTestRecord struct {
	AliasedRecord    AliasedRecord
	NestedTestRecord NestedTestRecord
	UnionType        UnionAliasedRecordNestedTestRecordTypeEnum
}

func DeserializeUnionAliasedRecordNestedTestRecord 

func DeserializeUnionAliasedRecordNestedTestRecord(r io.Reader) (UnionAliasedRecordNestedTestRecord, error)

func DeserializeUnionAliasedRecordNestedTestRecordFromSchema 

func DeserializeUnionAliasedRecordNestedTestRecordFromSchema(r io.Reader, schema string) (UnionAliasedRecordNestedTestRecord, error)

func NewUnionAliasedRecordNestedTestRecord 

func NewUnionAliasedRecordNestedTestRecord() UnionAliasedRecordNestedTestRecord

func (UnionAliasedRecordNestedTestRecord) AppendArray 

func (_ UnionAliasedRecordNestedTestRecord) AppendArray() types.Field

func (UnionAliasedRecordNestedTestRecord) AppendMap 

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

func (UnionAliasedRecordNestedTestRecord) Finalize 

func (_ UnionAliasedRecordNestedTestRecord) Finalize()

func (*UnionAliasedRecordNestedTestRecord) Get 

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

func (UnionAliasedRecordNestedTestRecord) HintSize 

func (_ UnionAliasedRecordNestedTestRecord) HintSize(i int)

func (UnionAliasedRecordNestedTestRecord) MarshalJSON 

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

func (UnionAliasedRecordNestedTestRecord) NullField 

func (_ UnionAliasedRecordNestedTestRecord) NullField(i int)

func (UnionAliasedRecordNestedTestRecord) Schema 

func (r UnionAliasedRecordNestedTestRecord) Schema() string

func (UnionAliasedRecordNestedTestRecord) Serialize 

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

func (UnionAliasedRecordNestedTestRecord) SetBoolean 

func (_ UnionAliasedRecordNestedTestRecord) SetBoolean(v bool)

func (UnionAliasedRecordNestedTestRecord) SetBytes 

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

func (UnionAliasedRecordNestedTestRecord) SetDefault 

func (_ UnionAliasedRecordNestedTestRecord) SetDefault(i int)

func (UnionAliasedRecordNestedTestRecord) SetDouble 

func (_ UnionAliasedRecordNestedTestRecord) SetDouble(v float64)

func (UnionAliasedRecordNestedTestRecord) SetFloat 

func (_ UnionAliasedRecordNestedTestRecord) SetFloat(v float32)

func (UnionAliasedRecordNestedTestRecord) SetInt 

func (_ UnionAliasedRecordNestedTestRecord) SetInt(v int32)

func (*UnionAliasedRecordNestedTestRecord) SetLong 

func (r *UnionAliasedRecordNestedTestRecord) SetLong(v int64)

func (UnionAliasedRecordNestedTestRecord) SetString 

func (_ UnionAliasedRecordNestedTestRecord) SetString(v string)

func (*UnionAliasedRecordNestedTestRecord) UnmarshalJSON 

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

type UnionAliasedRecordNestedTestRecordTypeEnum 

type UnionAliasedRecordNestedTestRecordTypeEnum int
const (
	UnionAliasedRecordNestedTestRecordTypeEnumAliasedRecord UnionAliasedRecordNestedTestRecordTypeEnum = 0

	UnionAliasedRecordNestedTestRecordTypeEnumNestedTestRecord UnionAliasedRecordNestedTestRecordTypeEnum = 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.