avro

Documentation

Overview

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

• SOURCE:
• example.avsc

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

• SOURCE:
• example.avsc

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

• SOURCE:
• example.avsc

Index

• Constants
• func NewDemoSchemaWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type Bytes
  • func (b Bytes) MarshalJSON() ([]byte, error)
  • func (b *Bytes) UnmarshalJSON(data []byte) error
• type BytesWrapper
  • func (b BytesWrapper) AppendArray() types.Field
  • func (b BytesWrapper) AppendMap(key string) types.Field
  • func (b BytesWrapper) Finalize()
  • func (b BytesWrapper) Get(i int) types.Field
  • func (b BytesWrapper) HintSize(int)
  • func (b BytesWrapper) NullField(int)
  • func (b BytesWrapper) SetBoolean(v bool)
  • func (b BytesWrapper) SetBytes(v []byte)
  • func (b BytesWrapper) SetDefault(i int)
  • func (b BytesWrapper) SetDouble(v float64)
  • func (b BytesWrapper) SetFloat(v float32)
  • func (b BytesWrapper) SetInt(v int32)
  • func (b BytesWrapper) SetLong(v int64)
  • func (b BytesWrapper) SetString(v string)
  • func (b BytesWrapper) SetUnionElem(v int64)
• type DemoSchema
  • func DeserializeDemoSchema(r io.Reader) (DemoSchema, error)
  • func DeserializeDemoSchemaFromSchema(r io.Reader, schema string) (DemoSchema, error)
  • func NewDemoSchema() DemoSchema
  • func (_ DemoSchema) AppendArray() types.Field
  • func (_ DemoSchema) AppendMap(key string) types.Field
  • func (_ DemoSchema) AvroCRC64Fingerprint() []byte
  • func (_ DemoSchema) Finalize()
  • func (r *DemoSchema) Get(i int) types.Field
  • func (_ DemoSchema) HintSize(int)
  • func (r DemoSchema) MarshalJSON() ([]byte, error)
  • func (r *DemoSchema) NullField(i int)
  • func (r DemoSchema) Schema() string
  • func (r DemoSchema) SchemaName() string
  • func (r DemoSchema) Serialize(w io.Writer) error
  • func (_ DemoSchema) SetBoolean(v bool)
  • func (_ DemoSchema) SetBytes(v []byte)
  • func (r *DemoSchema) SetDefault(i int)
  • func (_ DemoSchema) SetDouble(v float64)
  • func (_ DemoSchema) SetFloat(v float32)
  • func (_ DemoSchema) SetInt(v int32)
  • func (_ DemoSchema) SetLong(v int64)
  • func (_ DemoSchema) SetString(v string)
  • func (_ DemoSchema) SetUnionElem(v int64)
  • func (r *DemoSchema) UnmarshalJSON(data []byte) error
• type DemoSchemaReader
  • func NewDemoSchemaReader(r io.Reader) (*DemoSchemaReader, error)
  • func (r DemoSchemaReader) Read() (DemoSchema, error)

Constants

const DemoSchemaAvroCRC64Fingerprint = "\xc4V\xa9\x04ʛf\xad"

Functions

func NewDemoSchemaWriter

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

Types

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 DemoSchema

type DemoSchema struct {
	IntField int32 `json:"IntField"`

	DoubleField float64 `json:"DoubleField"`

	StringField string `json:"StringField"`

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

func DeserializeDemoSchema

func DeserializeDemoSchema(r io.Reader) (DemoSchema, error)

func DeserializeDemoSchemaFromSchema

func DeserializeDemoSchemaFromSchema(r io.Reader, schema string) (DemoSchema, error)

func NewDemoSchema

func NewDemoSchema() DemoSchema

func (DemoSchema) AppendArray

func (_ DemoSchema) AppendArray() types.Field

func (DemoSchema) AppendMap

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

func (DemoSchema) AvroCRC64Fingerprint

func (_ DemoSchema) AvroCRC64Fingerprint() []byte

func (DemoSchema) Finalize

func (_ DemoSchema) Finalize()

func (*DemoSchema) Get

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

func (DemoSchema) HintSize

func (_ DemoSchema) HintSize(int)

func (DemoSchema) MarshalJSON

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

func (*DemoSchema) NullField

func (r *DemoSchema) NullField(i int)

func (DemoSchema) Schema

func (r DemoSchema) Schema() string

func (DemoSchema) SchemaName

func (r DemoSchema) SchemaName() string

func (DemoSchema) Serialize

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

func (DemoSchema) SetBoolean

func (_ DemoSchema) SetBoolean(v bool)

func (DemoSchema) SetBytes

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

func (*DemoSchema) SetDefault

func (r *DemoSchema) SetDefault(i int)

func (DemoSchema) SetDouble

func (_ DemoSchema) SetDouble(v float64)

func (DemoSchema) SetFloat

func (_ DemoSchema) SetFloat(v float32)

func (DemoSchema) SetInt

func (_ DemoSchema) SetInt(v int32)

func (DemoSchema) SetLong

func (_ DemoSchema) SetLong(v int64)

func (DemoSchema) SetString

func (_ DemoSchema) SetString(v string)

func (DemoSchema) SetUnionElem

func (_ DemoSchema) SetUnionElem(v int64)

func (*DemoSchema) UnmarshalJSON

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

type DemoSchemaReader

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

container reader

func NewDemoSchemaReader

func NewDemoSchemaReader(r io.Reader) (*DemoSchemaReader, error)

func (DemoSchemaReader) Read

func (r DemoSchemaReader) Read() (DemoSchema, error)