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

Index

Constants

View Source 
const Record_v1AvroCRC64Fingerprint = "\x85|\xeb\x7f9\xf7J\x15"

Variables

This section is empty.

Functions

func NewRecord_v1Writer 

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

Types

type Record_v1 

type Record_v1 struct {
	Foo *UnionNullString `json:"foo"`

	Bar *UnionStringNull `json:"bar"`
}

func DeserializeRecord_v1 

func DeserializeRecord_v1(r io.Reader) (Record_v1, error)

func DeserializeRecord_v1FromSchema 

func DeserializeRecord_v1FromSchema(r io.Reader, schema string) (Record_v1, error)

func NewRecord_v1 

func NewRecord_v1() Record_v1

func (Record_v1) AppendArray 

func (_ Record_v1) AppendArray() types.Field

func (Record_v1) AppendMap 

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

func (Record_v1) AvroCRC64Fingerprint 

func (_ Record_v1) AvroCRC64Fingerprint() []byte

func (Record_v1) Finalize 

func (_ Record_v1) Finalize()

func (*Record_v1) Get 

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

func (Record_v1) HintSize 

func (_ Record_v1) HintSize(int)

func (Record_v1) MarshalJSON 

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

func (*Record_v1) NullField 

func (r *Record_v1) NullField(i int)

func (Record_v1) Schema 

func (r Record_v1) Schema() string

func (Record_v1) SchemaName 

func (r Record_v1) SchemaName() string

func (Record_v1) Serialize 

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

func (Record_v1) SetBoolean 

func (_ Record_v1) SetBoolean(v bool)

func (Record_v1) SetBytes 

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

func (*Record_v1) SetDefault 

func (r *Record_v1) SetDefault(i int)

func (Record_v1) SetDouble 

func (_ Record_v1) SetDouble(v float64)

func (Record_v1) SetFloat 

func (_ Record_v1) SetFloat(v float32)

func (Record_v1) SetInt 

func (_ Record_v1) SetInt(v int32)

func (Record_v1) SetLong 

func (_ Record_v1) SetLong(v int64)

func (Record_v1) SetString 

func (_ Record_v1) SetString(v string)

func (Record_v1) SetUnionElem 

func (_ Record_v1) SetUnionElem(v int64)

func (*Record_v1) UnmarshalJSON 

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

type Record_v1Reader 

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

container reader

func NewRecord_v1Reader 

func NewRecord_v1Reader(r io.Reader) (*Record_v1Reader, error)

func (Record_v1Reader) Read 

func (r Record_v1Reader) Read() (Record_v1, error)

type UnionNullString 

type UnionNullString struct {
	Null      *types.NullVal
	String    string
	UnionType UnionNullStringTypeEnum
}

func DeserializeUnionNullString 

func DeserializeUnionNullString(r io.Reader) (*UnionNullString, error)

func DeserializeUnionNullStringFromSchema 

func DeserializeUnionNullStringFromSchema(r io.Reader, schema string) (*UnionNullString, error)

func NewUnionNullString 

func NewUnionNullString() *UnionNullString

func (*UnionNullString) AppendArray 

func (_ *UnionNullString) AppendArray() types.Field

func (*UnionNullString) AppendMap 

func (_ *UnionNullString) AppendMap(key string) types.Field

func (*UnionNullString) Finalize 

func (_ *UnionNullString) Finalize()

func (*UnionNullString) Get 

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

func (*UnionNullString) HintSize 

func (_ *UnionNullString) HintSize(i int)

func (*UnionNullString) MarshalJSON 

func (r *UnionNullString) MarshalJSON() ([]byte, error)

func (*UnionNullString) NullField 

func (_ *UnionNullString) NullField(i int)

func (*UnionNullString) Schema 

func (r *UnionNullString) Schema() string

func (*UnionNullString) Serialize 

func (r *UnionNullString) Serialize(w io.Writer) error

func (*UnionNullString) SetBoolean 

func (_ *UnionNullString) SetBoolean(v bool)

func (*UnionNullString) SetBytes 

func (_ *UnionNullString) SetBytes(v []byte)

func (*UnionNullString) SetDefault 

func (_ *UnionNullString) SetDefault(i int)

func (*UnionNullString) SetDouble 

func (_ *UnionNullString) SetDouble(v float64)

func (*UnionNullString) SetFloat 

func (_ *UnionNullString) SetFloat(v float32)

func (*UnionNullString) SetInt 

func (_ *UnionNullString) SetInt(v int32)

func (*UnionNullString) SetLong 

func (r *UnionNullString) SetLong(v int64)

func (*UnionNullString) SetString 

func (_ *UnionNullString) SetString(v string)

func (*UnionNullString) UnmarshalJSON 

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

type UnionNullStringTypeEnum 

type UnionNullStringTypeEnum int
const (
	UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)

type UnionStringNull 

type UnionStringNull struct {
	String    string
	Null      *types.NullVal
	UnionType UnionStringNullTypeEnum
}

func DeserializeUnionStringNull 

func DeserializeUnionStringNull(r io.Reader) (*UnionStringNull, error)

func DeserializeUnionStringNullFromSchema 

func DeserializeUnionStringNullFromSchema(r io.Reader, schema string) (*UnionStringNull, error)

func NewUnionStringNull 

func NewUnionStringNull() *UnionStringNull

func (*UnionStringNull) AppendArray 

func (_ *UnionStringNull) AppendArray() types.Field

func (*UnionStringNull) AppendMap 

func (_ *UnionStringNull) AppendMap(key string) types.Field

func (*UnionStringNull) Finalize 

func (_ *UnionStringNull) Finalize()

func (*UnionStringNull) Get 

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

func (*UnionStringNull) HintSize 

func (_ *UnionStringNull) HintSize(i int)

func (*UnionStringNull) MarshalJSON 

func (r *UnionStringNull) MarshalJSON() ([]byte, error)

func (*UnionStringNull) NullField 

func (_ *UnionStringNull) NullField(i int)

func (*UnionStringNull) Schema 

func (r *UnionStringNull) Schema() string

func (*UnionStringNull) Serialize 

func (r *UnionStringNull) Serialize(w io.Writer) error

func (*UnionStringNull) SetBoolean 

func (_ *UnionStringNull) SetBoolean(v bool)

func (*UnionStringNull) SetBytes 

func (_ *UnionStringNull) SetBytes(v []byte)

func (*UnionStringNull) SetDefault 

func (_ *UnionStringNull) SetDefault(i int)

func (*UnionStringNull) SetDouble 

func (_ *UnionStringNull) SetDouble(v float64)

func (*UnionStringNull) SetFloat 

func (_ *UnionStringNull) SetFloat(v float32)

func (*UnionStringNull) SetInt 

func (_ *UnionStringNull) SetInt(v int32)

func (*UnionStringNull) SetLong 

func (r *UnionStringNull) SetLong(v int64)

func (*UnionStringNull) SetString 

func (_ *UnionStringNull) SetString(v string)

func (*UnionStringNull) UnmarshalJSON 

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

type UnionStringNullTypeEnum 

type UnionStringNullTypeEnum int
const (
	UnionStringNullTypeEnumString UnionStringNullTypeEnum = 0
)

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.