avro

package
v10.2.1 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2022 License: MIT Imports: 7 Imported by: 1

Documentation

Overview

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

Index

Constants

View Source
const AvroContainerBlockAvroCRC64Fingerprint = "\x0e\xecj@ٔ\xe14"
View Source
const AvroContainerHeaderAvroCRC64Fingerprint = "\xc0\x12\x03\xc0wi\xf96"

Variables

This section is empty.

Functions

This section is empty.

Types

type AvroContainerBlock

type AvroContainerBlock struct {
	NumRecords int64 `json:"numRecords"`

	RecordBytes Bytes `json:"recordBytes"`

	Sync Sync `json:"sync"`
}

func DeserializeAvroContainerBlock

func DeserializeAvroContainerBlock(r io.Reader) (AvroContainerBlock, error)

func DeserializeAvroContainerBlockFromSchema

func DeserializeAvroContainerBlockFromSchema(r io.Reader, schema string) (AvroContainerBlock, error)

func NewAvroContainerBlock

func NewAvroContainerBlock() AvroContainerBlock

func (AvroContainerBlock) AppendArray

func (_ AvroContainerBlock) AppendArray() types.Field

func (AvroContainerBlock) AppendMap

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

func (AvroContainerBlock) AvroCRC64Fingerprint

func (_ AvroContainerBlock) AvroCRC64Fingerprint() []byte

func (AvroContainerBlock) Finalize

func (_ AvroContainerBlock) Finalize()

func (*AvroContainerBlock) Get

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

func (AvroContainerBlock) HintSize

func (_ AvroContainerBlock) HintSize(int)

func (AvroContainerBlock) MarshalJSON

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

func (*AvroContainerBlock) NullField

func (r *AvroContainerBlock) NullField(i int)

func (AvroContainerBlock) Schema

func (r AvroContainerBlock) Schema() string

func (AvroContainerBlock) SchemaName

func (r AvroContainerBlock) SchemaName() string

func (AvroContainerBlock) Serialize

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

func (AvroContainerBlock) SetBoolean

func (_ AvroContainerBlock) SetBoolean(v bool)

func (AvroContainerBlock) SetBytes

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

func (*AvroContainerBlock) SetDefault

func (r *AvroContainerBlock) SetDefault(i int)

func (AvroContainerBlock) SetDouble

func (_ AvroContainerBlock) SetDouble(v float64)

func (AvroContainerBlock) SetFloat

func (_ AvroContainerBlock) SetFloat(v float32)

func (AvroContainerBlock) SetInt

func (_ AvroContainerBlock) SetInt(v int32)

func (AvroContainerBlock) SetLong

func (_ AvroContainerBlock) SetLong(v int64)

func (AvroContainerBlock) SetString

func (_ AvroContainerBlock) SetString(v string)

func (AvroContainerBlock) SetUnionElem

func (_ AvroContainerBlock) SetUnionElem(v int64)

func (*AvroContainerBlock) UnmarshalJSON

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

type AvroContainerHeader

type AvroContainerHeader struct {
	Magic Magic `json:"magic"`

	Meta map[string]Bytes `json:"meta"`

	Sync Sync `json:"sync"`
}

func DeserializeAvroContainerHeader

func DeserializeAvroContainerHeader(r io.Reader) (AvroContainerHeader, error)

func DeserializeAvroContainerHeaderFromSchema

func DeserializeAvroContainerHeaderFromSchema(r io.Reader, schema string) (AvroContainerHeader, error)

func NewAvroContainerHeader

func NewAvroContainerHeader() AvroContainerHeader

func (AvroContainerHeader) AppendArray

func (_ AvroContainerHeader) AppendArray() types.Field

func (AvroContainerHeader) AppendMap

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

func (AvroContainerHeader) AvroCRC64Fingerprint

func (_ AvroContainerHeader) AvroCRC64Fingerprint() []byte

func (AvroContainerHeader) Finalize

func (_ AvroContainerHeader) Finalize()

func (*AvroContainerHeader) Get

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

func (AvroContainerHeader) HintSize

func (_ AvroContainerHeader) HintSize(int)

func (AvroContainerHeader) MarshalJSON

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

func (*AvroContainerHeader) NullField

func (r *AvroContainerHeader) NullField(i int)

func (AvroContainerHeader) Schema

func (r AvroContainerHeader) Schema() string

func (AvroContainerHeader) SchemaName

func (r AvroContainerHeader) SchemaName() string

func (AvroContainerHeader) Serialize

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

func (AvroContainerHeader) SetBoolean

func (_ AvroContainerHeader) SetBoolean(v bool)

func (AvroContainerHeader) SetBytes

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

func (*AvroContainerHeader) SetDefault

func (r *AvroContainerHeader) SetDefault(i int)

func (AvroContainerHeader) SetDouble

func (_ AvroContainerHeader) SetDouble(v float64)

func (AvroContainerHeader) SetFloat

func (_ AvroContainerHeader) SetFloat(v float32)

func (AvroContainerHeader) SetInt

func (_ AvroContainerHeader) SetInt(v int32)

func (AvroContainerHeader) SetLong

func (_ AvroContainerHeader) SetLong(v int64)

func (AvroContainerHeader) SetString

func (_ AvroContainerHeader) SetString(v string)

func (AvroContainerHeader) SetUnionElem

func (_ AvroContainerHeader) SetUnionElem(v int64)

func (*AvroContainerHeader) UnmarshalJSON

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

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 Magic

type Magic [4]byte

func (Magic) MarshalJSON

func (b Magic) MarshalJSON() ([]byte, error)

func (*Magic) UnmarshalJSON

func (b *Magic) UnmarshalJSON(data []byte) error

type MagicWrapper

type MagicWrapper struct {
	Target *Magic
}

func (MagicWrapper) AppendArray

func (_ MagicWrapper) AppendArray() types.Field

func (MagicWrapper) AppendMap

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

func (MagicWrapper) Finalize

func (_ MagicWrapper) Finalize()

func (MagicWrapper) Get

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

func (MagicWrapper) HintSize

func (_ MagicWrapper) HintSize(int)

func (MagicWrapper) NullField

func (_ MagicWrapper) NullField(int)

func (MagicWrapper) SetBoolean

func (_ MagicWrapper) SetBoolean(v bool)

func (MagicWrapper) SetBytes

func (r MagicWrapper) SetBytes(v []byte)

func (MagicWrapper) SetDefault

func (_ MagicWrapper) SetDefault(i int)

func (MagicWrapper) SetDouble

func (_ MagicWrapper) SetDouble(v float64)

func (MagicWrapper) SetFloat

func (_ MagicWrapper) SetFloat(v float32)

func (MagicWrapper) SetInt

func (_ MagicWrapper) SetInt(v int32)

func (MagicWrapper) SetLong

func (_ MagicWrapper) SetLong(v int64)

func (MagicWrapper) SetString

func (_ MagicWrapper) SetString(v string)

func (MagicWrapper) SetUnionElem

func (_ MagicWrapper) SetUnionElem(v int64)

type MapBytesWrapper

type MapBytesWrapper struct {
	Target *map[string]Bytes
	// contains filtered or unexported fields
}

func (*MapBytesWrapper) AppendArray

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

func (*MapBytesWrapper) AppendMap

func (r *MapBytesWrapper) AppendMap(key string) types.Field

func (*MapBytesWrapper) Finalize

func (r *MapBytesWrapper) Finalize()

func (*MapBytesWrapper) Get

func (_ *MapBytesWrapper) Get(i int) types.Field

func (*MapBytesWrapper) HintSize

func (r *MapBytesWrapper) HintSize(s int)

func (*MapBytesWrapper) NullField

func (r *MapBytesWrapper) NullField(_ int)

func (*MapBytesWrapper) SetBoolean

func (_ *MapBytesWrapper) SetBoolean(v bool)

func (*MapBytesWrapper) SetBytes

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

func (*MapBytesWrapper) SetDefault

func (_ *MapBytesWrapper) SetDefault(i int)

func (*MapBytesWrapper) SetDouble

func (_ *MapBytesWrapper) SetDouble(v float64)

func (*MapBytesWrapper) SetFloat

func (_ *MapBytesWrapper) SetFloat(v float32)

func (*MapBytesWrapper) SetInt

func (_ *MapBytesWrapper) SetInt(v int32)

func (*MapBytesWrapper) SetLong

func (_ *MapBytesWrapper) SetLong(v int64)

func (*MapBytesWrapper) SetString

func (_ *MapBytesWrapper) SetString(v string)

func (*MapBytesWrapper) SetUnionElem

func (_ *MapBytesWrapper) SetUnionElem(v int64)

type Sync

type Sync [16]byte

func (Sync) MarshalJSON

func (b Sync) MarshalJSON() ([]byte, error)

func (*Sync) UnmarshalJSON

func (b *Sync) UnmarshalJSON(data []byte) error

type SyncWrapper

type SyncWrapper struct {
	Target *Sync
}

func (SyncWrapper) AppendArray

func (_ SyncWrapper) AppendArray() types.Field

func (SyncWrapper) AppendMap

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

func (SyncWrapper) Finalize

func (_ SyncWrapper) Finalize()

func (SyncWrapper) Get

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

func (SyncWrapper) HintSize

func (_ SyncWrapper) HintSize(int)

func (SyncWrapper) NullField

func (_ SyncWrapper) NullField(int)

func (SyncWrapper) SetBoolean

func (_ SyncWrapper) SetBoolean(v bool)

func (SyncWrapper) SetBytes

func (r SyncWrapper) SetBytes(v []byte)

func (SyncWrapper) SetDefault

func (_ SyncWrapper) SetDefault(i int)

func (SyncWrapper) SetDouble

func (_ SyncWrapper) SetDouble(v float64)

func (SyncWrapper) SetFloat

func (_ SyncWrapper) SetFloat(v float32)

func (SyncWrapper) SetInt

func (_ SyncWrapper) SetInt(v int32)

func (SyncWrapper) SetLong

func (_ SyncWrapper) SetLong(v int64)

func (SyncWrapper) SetString

func (_ SyncWrapper) SetString(v string)

func (SyncWrapper) SetUnionElem

func (_ SyncWrapper) SetUnionElem(v int64)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL