avro

package
v8.0.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.

  • SOURCE:
  • schema.avsc

Index

Constants

View Source 
const UnionRecordAvroCRC64Fingerprint = "\xfeS\x1bd\xa1\xfc͒"

Variables

This section is empty.

Functions

func NewUnionRecordWriter 

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

Types

type UnionInt 

type UnionInt struct {
	Null      *types.NullVal
	Int       int32
	UnionType UnionIntTypeEnum
}

func DeserializeUnionInt 

func DeserializeUnionInt(r io.Reader) (*UnionInt, error)

func DeserializeUnionIntFromSchema 

func DeserializeUnionIntFromSchema(r io.Reader, schema string) (*UnionInt, error)

func NewUnionInt 

func NewUnionInt() *UnionInt

func (*UnionInt) AppendArray 

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

func (*UnionInt) AppendMap 

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

func (*UnionInt) Finalize 

func (_ *UnionInt) Finalize()

func (*UnionInt) Get 

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

func (*UnionInt) MarshalJSON 

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

func (*UnionInt) NullField 

func (_ *UnionInt) NullField(i int)

func (*UnionInt) Schema 

func (r *UnionInt) Schema() string

func (*UnionInt) Serialize 

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

func (*UnionInt) SetBoolean 

func (_ *UnionInt) SetBoolean(v bool)

func (*UnionInt) SetBytes 

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

func (*UnionInt) SetDefault 

func (_ *UnionInt) SetDefault(i int)

func (*UnionInt) SetDouble 

func (_ *UnionInt) SetDouble(v float64)

func (*UnionInt) SetFloat 

func (_ *UnionInt) SetFloat(v float32)

func (*UnionInt) SetInt 

func (_ *UnionInt) SetInt(v int32)

func (*UnionInt) SetLong 

func (r *UnionInt) SetLong(v int64)

func (*UnionInt) SetString 

func (_ *UnionInt) SetString(v string)

func (*UnionInt) UnmarshalJSON 

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

type UnionIntTypeEnum 

type UnionIntTypeEnum int
const (
	UnionIntTypeEnumInt UnionIntTypeEnum = 1
)

type UnionRecord 

type UnionRecord struct {
	A string `json:"a"`

	Id *UnionInt `json:"id"`

	Name *UnionString `json:"name"`
}

func DeserializeUnionRecord 

func DeserializeUnionRecord(r io.Reader) (UnionRecord, error)

func DeserializeUnionRecordFromSchema 

func DeserializeUnionRecordFromSchema(r io.Reader, schema string) (UnionRecord, error)

func NewUnionRecord 

func NewUnionRecord() UnionRecord

func (UnionRecord) AppendArray 

func (_ UnionRecord) AppendArray() types.Field

func (UnionRecord) AppendMap 

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

func (UnionRecord) AvroCRC64Fingerprint 

func (_ UnionRecord) AvroCRC64Fingerprint() []byte

func (UnionRecord) Finalize 

func (_ UnionRecord) Finalize()

func (*UnionRecord) Get 

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

func (UnionRecord) MarshalJSON 

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

func (*UnionRecord) NullField 

func (r *UnionRecord) NullField(i int)

func (UnionRecord) Schema 

func (r UnionRecord) Schema() string

func (UnionRecord) SchemaName 

func (r UnionRecord) SchemaName() string

func (UnionRecord) Serialize 

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

func (UnionRecord) SetBoolean 

func (_ UnionRecord) SetBoolean(v bool)

func (UnionRecord) SetBytes 

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

func (*UnionRecord) SetDefault 

func (r *UnionRecord) SetDefault(i int)

func (UnionRecord) SetDouble 

func (_ UnionRecord) SetDouble(v float64)

func (UnionRecord) SetFloat 

func (_ UnionRecord) SetFloat(v float32)

func (UnionRecord) SetInt 

func (_ UnionRecord) SetInt(v int32)

func (UnionRecord) SetLong 

func (_ UnionRecord) SetLong(v int64)

func (UnionRecord) SetString 

func (_ UnionRecord) SetString(v string)

func (UnionRecord) SetUnionElem 

func (_ UnionRecord) SetUnionElem(v int64)

func (*UnionRecord) UnmarshalJSON 

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

type UnionRecordReader 

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

container reader

func NewUnionRecordReader 

func NewUnionRecordReader(r io.Reader) (*UnionRecordReader, error)

func (UnionRecordReader) Read 

func (r UnionRecordReader) Read() (UnionRecord, error)

type UnionString 

type UnionString struct {
	Null      *types.NullVal
	String    string
	UnionType UnionStringTypeEnum
}

func DeserializeUnionString 

func DeserializeUnionString(r io.Reader) (*UnionString, error)

func DeserializeUnionStringFromSchema 

func DeserializeUnionStringFromSchema(r io.Reader, schema string) (*UnionString, error)

func NewUnionString 

func NewUnionString() *UnionString

func (*UnionString) AppendArray 

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

func (*UnionString) AppendMap 

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

func (*UnionString) Finalize 

func (_ *UnionString) Finalize()

func (*UnionString) Get 

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

func (*UnionString) MarshalJSON 

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

func (*UnionString) NullField 

func (_ *UnionString) NullField(i int)

func (*UnionString) Schema 

func (r *UnionString) Schema() string

func (*UnionString) Serialize 

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

func (*UnionString) SetBoolean 

func (_ *UnionString) SetBoolean(v bool)

func (*UnionString) SetBytes 

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

func (*UnionString) SetDefault 

func (_ *UnionString) SetDefault(i int)

func (*UnionString) SetDouble 

func (_ *UnionString) SetDouble(v float64)

func (*UnionString) SetFloat 

func (_ *UnionString) SetFloat(v float32)

func (*UnionString) SetInt 

func (_ *UnionString) SetInt(v int32)

func (*UnionString) SetLong 

func (r *UnionString) SetLong(v int64)

func (*UnionString) SetString 

func (_ *UnionString) SetString(v string)

func (*UnionString) UnmarshalJSON 

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

type UnionStringTypeEnum 

type UnionStringTypeEnum int
const (
	UnionStringTypeEnumString UnionStringTypeEnum = 1
)

Source Files

View all Source files

Directories

Path Synopsis
Code generated by github.com/actgardner/gogen-avro/v8.
 Code generated by github.com/actgardner/gogen-avro/v8.

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.