avro

Documentation

Overview

Code generated by Skaidus. DO NOT EDIT.

• SOURCE:
• schema.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCE:
• schema.avsc

Index

• Constants
• func NewStructTagWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type StructTag
  • func DeserializeStructTag(r io.Reader) (StructTag, error)
  • func DeserializeStructTagFromSchema(r io.Reader, schema string) (StructTag, error)
  • func NewStructTag() StructTag
  • func (_ StructTag) AppendArray() types.Field
  • func (_ StructTag) AppendMap(key string) types.Field
  • func (_ StructTag) AvroCRC64Fingerprint() []byte
  • func (_ StructTag) Finalize()
  • func (r *StructTag) Get(i int) types.Field
  • func (_ StructTag) HintSize(int)
  • func (r StructTag) MarshalJSON() ([]byte, error)
  • func (r *StructTag) NullField(i int)
  • func (r StructTag) Schema() string
  • func (r StructTag) SchemaName() string
  • func (r StructTag) Serialize(w io.Writer) error
  • func (_ StructTag) SetBoolean(v bool)
  • func (_ StructTag) SetBytes(v []byte)
  • func (r *StructTag) SetDefault(i int)
  • func (_ StructTag) SetDouble(v float64)
  • func (_ StructTag) SetFloat(v float32)
  • func (_ StructTag) SetInt(v int32)
  • func (_ StructTag) SetLong(v int64)
  • func (_ StructTag) SetString(v string)
  • func (_ StructTag) SetUnionElem(v int64)
  • func (r *StructTag) UnmarshalJSON(data []byte) error
• type StructTagReader
  • func NewStructTagReader(r io.Reader) (*StructTagReader, error)
  • func (r StructTagReader) Read() (StructTag, error)

Constants

const StructTagAvroCRC64Fingerprint = "\x92\xb7Dk\xe2\x1e\xef\xfc"

Functions

func NewStructTagWriter

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

Types

type StructTag

type StructTag struct {
	ProductName string `validate:"true" json:"productName"`
}

func DeserializeStructTag

func DeserializeStructTag(r io.Reader) (StructTag, error)

func DeserializeStructTagFromSchema

func DeserializeStructTagFromSchema(r io.Reader, schema string) (StructTag, error)

func NewStructTag

func NewStructTag() StructTag

func (StructTag) AppendArray

func (_ StructTag) AppendArray() types.Field

func (StructTag) AppendMap

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

func (StructTag) AvroCRC64Fingerprint

func (_ StructTag) AvroCRC64Fingerprint() []byte

func (StructTag) Finalize

func (_ StructTag) Finalize()

func (*StructTag) Get

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

func (StructTag) HintSize

func (_ StructTag) HintSize(int)

func (StructTag) MarshalJSON

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

func (*StructTag) NullField

func (r *StructTag) NullField(i int)

func (StructTag) Schema

func (r StructTag) Schema() string

func (StructTag) SchemaName

func (r StructTag) SchemaName() string

func (StructTag) Serialize

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

func (StructTag) SetBoolean

func (_ StructTag) SetBoolean(v bool)

func (StructTag) SetBytes

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

func (*StructTag) SetDefault

func (r *StructTag) SetDefault(i int)

func (StructTag) SetDouble

func (_ StructTag) SetDouble(v float64)

func (StructTag) SetFloat

func (_ StructTag) SetFloat(v float32)

func (StructTag) SetInt

func (_ StructTag) SetInt(v int32)

func (StructTag) SetLong

func (_ StructTag) SetLong(v int64)

func (StructTag) SetString

func (_ StructTag) SetString(v string)

func (StructTag) SetUnionElem

func (_ StructTag) SetUnionElem(v int64)

func (*StructTag) UnmarshalJSON

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

type StructTagReader

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

container reader

func NewStructTagReader

func NewStructTagReader(r io.Reader) (*StructTagReader, error)

func (StructTagReader) Read

func (r StructTagReader) Read() (StructTag, error)