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: 7 Imported by: 0

Documentation

Overview

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Index

Constants

View Source 
const RecordBarAvroCRC64Fingerprint = "0\x99\x1e\"\x92\xe1\x82{"
View Source 
const RecordFooAvroCRC64Fingerprint = "\x94\f\x14v\xb3\x98ߴ"
View Source 
const RecordSchemaAvroCRC64Fingerprint = "\xb8\xce$\xde\v\xd5\x00<"

Variables

This section is empty.

Functions

func NewRecordBarWriter 

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

func NewRecordFooWriter 

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

func NewRecordSchemaWriter 

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

Types

type ArrayUnionRecordFooRecordBarWrapper 

type ArrayUnionRecordFooRecordBarWrapper struct {
	Target *[]UnionRecordFooRecordBar
}

func (ArrayUnionRecordFooRecordBarWrapper) AppendArray 

func (r ArrayUnionRecordFooRecordBarWrapper) AppendArray() types.Field

func (ArrayUnionRecordFooRecordBarWrapper) AppendMap 

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

func (ArrayUnionRecordFooRecordBarWrapper) Finalize 

func (_ ArrayUnionRecordFooRecordBarWrapper) Finalize()

func (ArrayUnionRecordFooRecordBarWrapper) Get 

func (_ ArrayUnionRecordFooRecordBarWrapper) Get(i int) types.Field

func (ArrayUnionRecordFooRecordBarWrapper) HintSize 

func (r ArrayUnionRecordFooRecordBarWrapper) HintSize(s int)

func (ArrayUnionRecordFooRecordBarWrapper) NullField 

func (r ArrayUnionRecordFooRecordBarWrapper) NullField(i int)

func (ArrayUnionRecordFooRecordBarWrapper) SetBoolean 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetBoolean(v bool)

func (ArrayUnionRecordFooRecordBarWrapper) SetBytes 

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

func (ArrayUnionRecordFooRecordBarWrapper) SetDefault 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetDefault(i int)

func (ArrayUnionRecordFooRecordBarWrapper) SetDouble 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetDouble(v float64)

func (ArrayUnionRecordFooRecordBarWrapper) SetFloat 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetFloat(v float32)

func (ArrayUnionRecordFooRecordBarWrapper) SetInt 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetInt(v int32)

func (ArrayUnionRecordFooRecordBarWrapper) SetLong 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetLong(v int64)

func (ArrayUnionRecordFooRecordBarWrapper) SetString 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetString(v string)

func (ArrayUnionRecordFooRecordBarWrapper) SetUnionElem 

func (_ ArrayUnionRecordFooRecordBarWrapper) SetUnionElem(v int64)

type RecordBar 

type RecordBar struct {
	Id string `json:"id"`
}

func DeserializeRecordBar 

func DeserializeRecordBar(r io.Reader) (RecordBar, error)

func DeserializeRecordBarFromSchema 

func DeserializeRecordBarFromSchema(r io.Reader, schema string) (RecordBar, error)

func NewRecordBar 

func NewRecordBar() RecordBar

func (RecordBar) AppendArray 

func (_ RecordBar) AppendArray() types.Field

func (RecordBar) AppendMap 

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

func (RecordBar) AvroCRC64Fingerprint 

func (_ RecordBar) AvroCRC64Fingerprint() []byte

func (RecordBar) Finalize 

func (_ RecordBar) Finalize()

func (*RecordBar) Get 

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

func (RecordBar) HintSize 

func (_ RecordBar) HintSize(int)

func (RecordBar) MarshalJSON 

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

func (*RecordBar) NullField 

func (r *RecordBar) NullField(i int)

func (RecordBar) Schema 

func (r RecordBar) Schema() string

func (RecordBar) SchemaName 

func (r RecordBar) SchemaName() string

func (RecordBar) Serialize 

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

func (RecordBar) SetBoolean 

func (_ RecordBar) SetBoolean(v bool)

func (RecordBar) SetBytes 

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

func (*RecordBar) SetDefault 

func (r *RecordBar) SetDefault(i int)

func (RecordBar) SetDouble 

func (_ RecordBar) SetDouble(v float64)

func (RecordBar) SetFloat 

func (_ RecordBar) SetFloat(v float32)

func (RecordBar) SetInt 

func (_ RecordBar) SetInt(v int32)

func (RecordBar) SetLong 

func (_ RecordBar) SetLong(v int64)

func (RecordBar) SetString 

func (_ RecordBar) SetString(v string)

func (RecordBar) SetUnionElem 

func (_ RecordBar) SetUnionElem(v int64)

func (*RecordBar) UnmarshalJSON 

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

type RecordBarReader 

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

container reader

func NewRecordBarReader 

func NewRecordBarReader(r io.Reader) (*RecordBarReader, error)

func (RecordBarReader) Read 

func (r RecordBarReader) Read() (RecordBar, error)

type RecordFoo 

type RecordFoo struct {
	Id string `json:"id"`
}

func DeserializeRecordFoo 

func DeserializeRecordFoo(r io.Reader) (RecordFoo, error)

func DeserializeRecordFooFromSchema 

func DeserializeRecordFooFromSchema(r io.Reader, schema string) (RecordFoo, error)

func NewRecordFoo 

func NewRecordFoo() RecordFoo

func (RecordFoo) AppendArray 

func (_ RecordFoo) AppendArray() types.Field

func (RecordFoo) AppendMap 

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

func (RecordFoo) AvroCRC64Fingerprint 

func (_ RecordFoo) AvroCRC64Fingerprint() []byte

func (RecordFoo) Finalize 

func (_ RecordFoo) Finalize()

func (*RecordFoo) Get 

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

func (RecordFoo) HintSize 

func (_ RecordFoo) HintSize(int)

func (RecordFoo) MarshalJSON 

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

func (*RecordFoo) NullField 

func (r *RecordFoo) NullField(i int)

func (RecordFoo) Schema 

func (r RecordFoo) Schema() string

func (RecordFoo) SchemaName 

func (r RecordFoo) SchemaName() string

func (RecordFoo) Serialize 

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

func (RecordFoo) SetBoolean 

func (_ RecordFoo) SetBoolean(v bool)

func (RecordFoo) SetBytes 

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

func (*RecordFoo) SetDefault 

func (r *RecordFoo) SetDefault(i int)

func (RecordFoo) SetDouble 

func (_ RecordFoo) SetDouble(v float64)

func (RecordFoo) SetFloat 

func (_ RecordFoo) SetFloat(v float32)

func (RecordFoo) SetInt 

func (_ RecordFoo) SetInt(v int32)

func (RecordFoo) SetLong 

func (_ RecordFoo) SetLong(v int64)

func (RecordFoo) SetString 

func (_ RecordFoo) SetString(v string)

func (RecordFoo) SetUnionElem 

func (_ RecordFoo) SetUnionElem(v int64)

func (*RecordFoo) UnmarshalJSON 

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

type RecordFooReader 

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

container reader

func NewRecordFooReader 

func NewRecordFooReader(r io.Reader) (*RecordFooReader, error)

func (RecordFooReader) Read 

func (r RecordFooReader) Read() (RecordFoo, error)

type RecordSchema 

type RecordSchema struct {
	Data []UnionRecordFooRecordBar `json:"data"`
}

func DeserializeRecordSchema 

func DeserializeRecordSchema(r io.Reader) (RecordSchema, error)

func DeserializeRecordSchemaFromSchema 

func DeserializeRecordSchemaFromSchema(r io.Reader, schema string) (RecordSchema, error)

func NewRecordSchema 

func NewRecordSchema() RecordSchema

func (RecordSchema) AppendArray 

func (_ RecordSchema) AppendArray() types.Field

func (RecordSchema) AppendMap 

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

func (RecordSchema) AvroCRC64Fingerprint 

func (_ RecordSchema) AvroCRC64Fingerprint() []byte

func (RecordSchema) Finalize 

func (_ RecordSchema) Finalize()

func (*RecordSchema) Get 

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

func (RecordSchema) HintSize 

func (_ RecordSchema) HintSize(int)

func (RecordSchema) MarshalJSON 

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

func (*RecordSchema) NullField 

func (r *RecordSchema) NullField(i int)

func (RecordSchema) Schema 

func (r RecordSchema) Schema() string

func (RecordSchema) SchemaName 

func (r RecordSchema) SchemaName() string

func (RecordSchema) Serialize 

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

func (RecordSchema) SetBoolean 

func (_ RecordSchema) SetBoolean(v bool)

func (RecordSchema) SetBytes 

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

func (*RecordSchema) SetDefault 

func (r *RecordSchema) SetDefault(i int)

func (RecordSchema) SetDouble 

func (_ RecordSchema) SetDouble(v float64)

func (RecordSchema) SetFloat 

func (_ RecordSchema) SetFloat(v float32)

func (RecordSchema) SetInt 

func (_ RecordSchema) SetInt(v int32)

func (RecordSchema) SetLong 

func (_ RecordSchema) SetLong(v int64)

func (RecordSchema) SetString 

func (_ RecordSchema) SetString(v string)

func (RecordSchema) SetUnionElem 

func (_ RecordSchema) SetUnionElem(v int64)

func (*RecordSchema) UnmarshalJSON 

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

type RecordSchemaReader 

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

container reader

func NewRecordSchemaReader 

func NewRecordSchemaReader(r io.Reader) (*RecordSchemaReader, error)

func (RecordSchemaReader) Read 

func (r RecordSchemaReader) Read() (RecordSchema, error)

type UnionRecordFooRecordBar 

type UnionRecordFooRecordBar struct {
	RecordFoo RecordFoo
	RecordBar RecordBar
	UnionType UnionRecordFooRecordBarTypeEnum
}

func DeserializeUnionRecordFooRecordBar 

func DeserializeUnionRecordFooRecordBar(r io.Reader) (UnionRecordFooRecordBar, error)

func DeserializeUnionRecordFooRecordBarFromSchema 

func DeserializeUnionRecordFooRecordBarFromSchema(r io.Reader, schema string) (UnionRecordFooRecordBar, error)

func NewUnionRecordFooRecordBar 

func NewUnionRecordFooRecordBar() UnionRecordFooRecordBar

func (UnionRecordFooRecordBar) AppendArray 

func (_ UnionRecordFooRecordBar) AppendArray() types.Field

func (UnionRecordFooRecordBar) AppendMap 

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

func (UnionRecordFooRecordBar) Finalize 

func (_ UnionRecordFooRecordBar) Finalize()

func (*UnionRecordFooRecordBar) Get 

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

func (UnionRecordFooRecordBar) HintSize 

func (_ UnionRecordFooRecordBar) HintSize(i int)

func (UnionRecordFooRecordBar) MarshalJSON 

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

func (UnionRecordFooRecordBar) NullField 

func (_ UnionRecordFooRecordBar) NullField(i int)

func (UnionRecordFooRecordBar) Schema 

func (r UnionRecordFooRecordBar) Schema() string

func (UnionRecordFooRecordBar) Serialize 

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

func (UnionRecordFooRecordBar) SetBoolean 

func (_ UnionRecordFooRecordBar) SetBoolean(v bool)

func (UnionRecordFooRecordBar) SetBytes 

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

func (UnionRecordFooRecordBar) SetDefault 

func (_ UnionRecordFooRecordBar) SetDefault(i int)

func (UnionRecordFooRecordBar) SetDouble 

func (_ UnionRecordFooRecordBar) SetDouble(v float64)

func (UnionRecordFooRecordBar) SetFloat 

func (_ UnionRecordFooRecordBar) SetFloat(v float32)

func (UnionRecordFooRecordBar) SetInt 

func (_ UnionRecordFooRecordBar) SetInt(v int32)

func (*UnionRecordFooRecordBar) SetLong 

func (r *UnionRecordFooRecordBar) SetLong(v int64)

func (UnionRecordFooRecordBar) SetString 

func (_ UnionRecordFooRecordBar) SetString(v string)

func (*UnionRecordFooRecordBar) UnmarshalJSON 

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

type UnionRecordFooRecordBarTypeEnum 

type UnionRecordFooRecordBarTypeEnum int
const (
	UnionRecordFooRecordBarTypeEnumRecordFoo UnionRecordFooRecordBarTypeEnum = 0

	UnionRecordFooRecordBarTypeEnumRecordBar UnionRecordFooRecordBarTypeEnum = 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.