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

Index

Constants

View Source 
const PrimitiveTestRecordAvroCRC64Fingerprint = "۲\x16\xe9\xfet@\x13"

Variables

This section is empty.

Functions

func NewPrimitiveTestRecordWriter 

func NewPrimitiveTestRecordWriter(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 PrimitiveTestRecord 

type PrimitiveTestRecord struct {
	// int field
	IntField int32 `json:"IntField"`

	LongField int64 `json:"LongField"`

	FloatField float32 `json:"FloatField"`

	DoubleField float64 `json:"DoubleField"`

	StringField string `json:"StringField"`

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

primitive record

func DeserializePrimitiveTestRecord 

func DeserializePrimitiveTestRecord(r io.Reader) (PrimitiveTestRecord, error)

func DeserializePrimitiveTestRecordFromSchema 

func DeserializePrimitiveTestRecordFromSchema(r io.Reader, schema string) (PrimitiveTestRecord, error)

func NewPrimitiveTestRecord 

func NewPrimitiveTestRecord() PrimitiveTestRecord

func (PrimitiveTestRecord) AppendArray 

func (_ PrimitiveTestRecord) AppendArray() types.Field

func (PrimitiveTestRecord) AppendMap 

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

func (PrimitiveTestRecord) AvroCRC64Fingerprint 

func (_ PrimitiveTestRecord) AvroCRC64Fingerprint() []byte

func (PrimitiveTestRecord) Finalize 

func (_ PrimitiveTestRecord) Finalize()

func (*PrimitiveTestRecord) Get 

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

func (PrimitiveTestRecord) HintSize 

func (_ PrimitiveTestRecord) HintSize(int)

func (PrimitiveTestRecord) MarshalJSON 

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

func (*PrimitiveTestRecord) NullField 

func (r *PrimitiveTestRecord) NullField(i int)

func (PrimitiveTestRecord) Schema 

func (r PrimitiveTestRecord) Schema() string

func (PrimitiveTestRecord) SchemaName 

func (r PrimitiveTestRecord) SchemaName() string

func (PrimitiveTestRecord) Serialize 

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

func (PrimitiveTestRecord) SetBoolean 

func (_ PrimitiveTestRecord) SetBoolean(v bool)

func (PrimitiveTestRecord) SetBytes 

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

func (*PrimitiveTestRecord) SetDefault 

func (r *PrimitiveTestRecord) SetDefault(i int)

func (PrimitiveTestRecord) SetDouble 

func (_ PrimitiveTestRecord) SetDouble(v float64)

func (PrimitiveTestRecord) SetFloat 

func (_ PrimitiveTestRecord) SetFloat(v float32)

func (PrimitiveTestRecord) SetInt 

func (_ PrimitiveTestRecord) SetInt(v int32)

func (PrimitiveTestRecord) SetLong 

func (_ PrimitiveTestRecord) SetLong(v int64)

func (PrimitiveTestRecord) SetString 

func (_ PrimitiveTestRecord) SetString(v string)

func (PrimitiveTestRecord) SetUnionElem 

func (_ PrimitiveTestRecord) SetUnionElem(v int64)

func (*PrimitiveTestRecord) UnmarshalJSON 

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

type PrimitiveTestRecordReader 

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

container reader

func NewPrimitiveTestRecordReader 

func NewPrimitiveTestRecordReader(r io.Reader) (*PrimitiveTestRecordReader, error)

func (PrimitiveTestRecordReader) Read 

func (r PrimitiveTestRecordReader) Read() (PrimitiveTestRecord, error)

Source Files

View all Source files

Directories

Path Synopsis
Code generated by Skaidus.
 Code generated by Skaidus.

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.