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 NewStringRecWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type StringRec
  • func DeserializeStringRec(r io.Reader) (StringRec, error)
  • func DeserializeStringRecFromSchema(r io.Reader, schema string) (StringRec, error)
  • func NewStringRec() StringRec
  • func (_ StringRec) AppendArray() types.Field
  • func (_ StringRec) AppendMap(key string) types.Field
  • func (_ StringRec) AvroCRC64Fingerprint() []byte
  • func (_ StringRec) Finalize()
  • func (r *StringRec) Get(i int) types.Field
  • func (_ StringRec) HintSize(int)
  • func (r StringRec) MarshalJSON() ([]byte, error)
  • func (r *StringRec) NullField(i int)
  • func (r StringRec) Schema() string
  • func (r StringRec) SchemaName() string
  • func (r StringRec) Serialize(w io.Writer) error
  • func (_ StringRec) SetBoolean(v bool)
  • func (_ StringRec) SetBytes(v []byte)
  • func (r *StringRec) SetDefault(i int)
  • func (_ StringRec) SetDouble(v float64)
  • func (_ StringRec) SetFloat(v float32)
  • func (_ StringRec) SetInt(v int32)
  • func (_ StringRec) SetLong(v int64)
  • func (_ StringRec) SetString(v string)
  • func (_ StringRec) SetUnionElem(v int64)
  • func (r *StringRec) UnmarshalJSON(data []byte) error
• type StringRecReader
  • func NewStringRecReader(r io.Reader) (*StringRecReader, error)
  • func (r StringRecReader) Read() (StringRec, error)

Constants

const StringRecAvroCRC64Fingerprint = "w\x836\xab\x9d\xe9\x00\x15"

Functions

func NewStringRecWriter

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

Types

type StringRec

type StringRec struct {
	ProductName string `json:"productName"`
}

func DeserializeStringRec

func DeserializeStringRec(r io.Reader) (StringRec, error)

func DeserializeStringRecFromSchema

func DeserializeStringRecFromSchema(r io.Reader, schema string) (StringRec, error)

func NewStringRec

func NewStringRec() StringRec

func (StringRec) AppendArray

func (_ StringRec) AppendArray() types.Field

func (StringRec) AppendMap

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

func (StringRec) AvroCRC64Fingerprint

func (_ StringRec) AvroCRC64Fingerprint() []byte

func (StringRec) Finalize

func (_ StringRec) Finalize()

func (*StringRec) Get

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

func (StringRec) HintSize

func (_ StringRec) HintSize(int)

func (StringRec) MarshalJSON

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

func (*StringRec) NullField

func (r *StringRec) NullField(i int)

func (StringRec) Schema

func (r StringRec) Schema() string

func (StringRec) SchemaName

func (r StringRec) SchemaName() string

func (StringRec) Serialize

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

func (StringRec) SetBoolean

func (_ StringRec) SetBoolean(v bool)

func (StringRec) SetBytes

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

func (*StringRec) SetDefault

func (r *StringRec) SetDefault(i int)

func (StringRec) SetDouble

func (_ StringRec) SetDouble(v float64)

func (StringRec) SetFloat

func (_ StringRec) SetFloat(v float32)

func (StringRec) SetInt

func (_ StringRec) SetInt(v int32)

func (StringRec) SetLong

func (_ StringRec) SetLong(v int64)

func (StringRec) SetString

func (_ StringRec) SetString(v string)

func (StringRec) SetUnionElem

func (_ StringRec) SetUnionElem(v int64)

func (*StringRec) UnmarshalJSON

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

type StringRecReader

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

container reader

func NewStringRecReader

func NewStringRecReader(r io.Reader) (*StringRecReader, error)

func (StringRecReader) Read

func (r StringRecReader) Read() (StringRec, error)