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:
  • 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 NestedRecordAvroCRC64Fingerprint = "\x81\x8d\xc3K?\xe83\xcc"
View Source 
const NestedTestRecordAvroCRC64Fingerprint = "b{m\\D\xbe\xaa\x96"
View Source 
const NumberRecordAvroCRC64Fingerprint = "\xf4Zu\xd5Nt'~"

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)

func NewNumberRecordWriter 

func NewNumberRecordWriter(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 {
	NumberField NumberRecord `json:"NumberField"`

	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 NumberRecord 

type NumberRecord struct {
	IntField int32 `json:"IntField"`

	LongField int64 `json:"LongField"`

	FloatField float32 `json:"FloatField"`

	DoubleField float64 `json:"DoubleField"`
}

func DeserializeNumberRecord 

func DeserializeNumberRecord(r io.Reader) (NumberRecord, error)

func DeserializeNumberRecordFromSchema 

func DeserializeNumberRecordFromSchema(r io.Reader, schema string) (NumberRecord, error)

func NewNumberRecord 

func NewNumberRecord() NumberRecord

func (NumberRecord) AppendArray 

func (_ NumberRecord) AppendArray() types.Field

func (NumberRecord) AppendMap 

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

func (NumberRecord) AvroCRC64Fingerprint 

func (_ NumberRecord) AvroCRC64Fingerprint() []byte

func (NumberRecord) Finalize 

func (_ NumberRecord) Finalize()

func (*NumberRecord) Get 

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

func (NumberRecord) HintSize 

func (_ NumberRecord) HintSize(int)

func (NumberRecord) MarshalJSON 

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

func (*NumberRecord) NullField 

func (r *NumberRecord) NullField(i int)

func (NumberRecord) Schema 

func (r NumberRecord) Schema() string

func (NumberRecord) SchemaName 

func (r NumberRecord) SchemaName() string

func (NumberRecord) Serialize 

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

func (NumberRecord) SetBoolean 

func (_ NumberRecord) SetBoolean(v bool)

func (NumberRecord) SetBytes 

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

func (*NumberRecord) SetDefault 

func (r *NumberRecord) SetDefault(i int)

func (NumberRecord) SetDouble 

func (_ NumberRecord) SetDouble(v float64)

func (NumberRecord) SetFloat 

func (_ NumberRecord) SetFloat(v float32)

func (NumberRecord) SetInt 

func (_ NumberRecord) SetInt(v int32)

func (NumberRecord) SetLong 

func (_ NumberRecord) SetLong(v int64)

func (NumberRecord) SetString 

func (_ NumberRecord) SetString(v string)

func (NumberRecord) SetUnionElem 

func (_ NumberRecord) SetUnionElem(v int64)

func (*NumberRecord) UnmarshalJSON 

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

type NumberRecordReader 

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

container reader

func NewNumberRecordReader 

func NewNumberRecordReader(r io.Reader) (*NumberRecordReader, error)

func (NumberRecordReader) Read 

func (r NumberRecordReader) Read() (NumberRecord, error)

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.