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.

  • SOURCES:
  • block.avsc
  • header.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCES:
  • block.avsc
  • header.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCES:
  • block.avsc
  • header.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCES:
  • block.avsc
  • header.avsc

Code generated by Skaidus. DO NOT EDIT.

  • SOURCES:
  • block.avsc
  • header.avsc

Code generated by Skaidus. 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)

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.