avro

package
v9.0.0-...-018aada Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

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

  • SOURCES:
  • block.avsc
  • header.avsc

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AvroContainerBlock 

type AvroContainerBlock struct {
	NumRecords int64

	RecordBytes []byte

	Sync Sync
}

func DeserializeAvroContainerBlock 

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

func DeserializeAvroContainerBlockFromSchema 

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

func (*AvroContainerBlock) AppendArray 

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

func (*AvroContainerBlock) AppendMap 

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

func (*AvroContainerBlock) Clear 

func (r *AvroContainerBlock) Clear(i int)

func (*AvroContainerBlock) Finalize 

func (_ *AvroContainerBlock) Finalize()

func (*AvroContainerBlock) Get 

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

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)

type AvroContainerHeader 

type AvroContainerHeader struct {
	Magic Magic

	Meta MapBytes

	Sync Sync
}

func DeserializeAvroContainerHeader 

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

func DeserializeAvroContainerHeaderFromSchema 

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

func (*AvroContainerHeader) AppendArray 

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

func (*AvroContainerHeader) AppendMap 

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

func (*AvroContainerHeader) Clear 

func (r *AvroContainerHeader) Clear(i int)

func (*AvroContainerHeader) Finalize 

func (_ *AvroContainerHeader) Finalize()

func (*AvroContainerHeader) Get 

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

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)

type Magic 

type Magic [4]byte

func (*Magic) AppendArray 

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

func (*Magic) AppendMap 

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

func (*Magic) Clear 

func (_ *Magic) Clear(i int)

func (*Magic) Finalize 

func (_ *Magic) Finalize()

func (*Magic) Get 

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

func (*Magic) SetBoolean 

func (_ *Magic) SetBoolean(v bool)

func (*Magic) SetBytes 

func (r *Magic) SetBytes(v []byte)

func (*Magic) SetDefault 

func (_ *Magic) SetDefault(i int)

func (*Magic) SetDouble 

func (_ *Magic) SetDouble(v float64)

func (*Magic) SetFloat 

func (_ *Magic) SetFloat(v float32)

func (*Magic) SetInt 

func (_ *Magic) SetInt(v int32)

func (*Magic) SetLong 

func (_ *Magic) SetLong(v int64)

func (*Magic) SetString 

func (_ *Magic) SetString(v string)

func (*Magic) SetUnionElem 

func (_ *Magic) SetUnionElem(v int64)

type MapBytes 

type MapBytes struct {
	M map[string][]byte
	// contains filtered or unexported fields
}

func NewMapBytes 

func NewMapBytes() MapBytes

func (*MapBytes) AppendArray 

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

func (*MapBytes) AppendMap 

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

func (*MapBytes) Clear 

func (r *MapBytes) Clear(i int)

func (*MapBytes) Finalize 

func (r *MapBytes) Finalize()

func (*MapBytes) Get 

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

func (*MapBytes) SetBoolean 

func (_ *MapBytes) SetBoolean(v bool)

func (*MapBytes) SetBytes 

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

func (*MapBytes) SetDefault 

func (_ *MapBytes) SetDefault(i int)

func (*MapBytes) SetDouble 

func (_ *MapBytes) SetDouble(v float64)

func (*MapBytes) SetFloat 

func (_ *MapBytes) SetFloat(v float32)

func (*MapBytes) SetInt 

func (_ *MapBytes) SetInt(v int32)

func (*MapBytes) SetLong 

func (_ *MapBytes) SetLong(v int64)

func (*MapBytes) SetString 

func (_ *MapBytes) SetString(v string)

func (*MapBytes) SetUnionElem 

func (_ *MapBytes) SetUnionElem(v int64)

type Sync 

type Sync [16]byte

func (*Sync) AppendArray 

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

func (*Sync) AppendMap 

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

func (*Sync) Clear 

func (_ *Sync) Clear(i int)

func (*Sync) Finalize 

func (_ *Sync) Finalize()

func (*Sync) Get 

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

func (*Sync) SetBoolean 

func (_ *Sync) SetBoolean(v bool)

func (*Sync) SetBytes 

func (r *Sync) SetBytes(v []byte)

func (*Sync) SetDefault 

func (_ *Sync) SetDefault(i int)

func (*Sync) SetDouble 

func (_ *Sync) SetDouble(v float64)

func (*Sync) SetFloat 

func (_ *Sync) SetFloat(v float32)

func (*Sync) SetInt 

func (_ *Sync) SetInt(v int32)

func (*Sync) SetLong 

func (_ *Sync) SetLong(v int64)

func (*Sync) SetString 

func (_ *Sync) SetString(v string)

func (*Sync) SetUnionElem 

func (_ *Sync) 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.
JackTT - Gopher 🇻🇳