times

Documentation

Overview

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

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

Index

• Constants
• type Times
  • func DeserializeTimes(r io.Reader) (*Times, error)
  • func DeserializeTimesFromSchema(r io.Reader, schema string) (*Times, error)
  • func NewTimes() *Times
  • func (_ *Times) AppendArray() types.Field
  • func (_ *Times) AppendMap(key string) types.Field
  • func (_ *Times) AvroCRC64Fingerprint() []byte
  • func (_ *Times) Finalize()
  • func (r *Times) Get(i int) types.Field
  • func (r *Times) NullField(i int)
  • func (r *Times) Schema() string
  • func (r *Times) SchemaName() string
  • func (r *Times) Serialize(w io.Writer) error
  • func (_ *Times) SetBoolean(v bool)
  • func (_ *Times) SetBytes(v []byte)
  • func (r *Times) SetDefault(i int)
  • func (_ *Times) SetDouble(v float64)
  • func (_ *Times) SetFloat(v float32)
  • func (_ *Times) SetInt(v int32)
  • func (_ *Times) SetLong(v int64)
  • func (_ *Times) SetString(v string)
  • func (_ *Times) SetUnionElem(v int64)
• type UnionNullLong
  • func NewUnionNullLong() *UnionNullLong
  • func (_ *UnionNullLong) AppendArray() types.Field
  • func (_ *UnionNullLong) AppendMap(key string) types.Field
  • func (_ *UnionNullLong) Finalize()
  • func (r *UnionNullLong) Get(i int) types.Field
  • func (r *UnionNullLong) MarshalJSON() ([]byte, error)
  • func (_ *UnionNullLong) NullField(i int)
  • func (_ *UnionNullLong) SetBoolean(v bool)
  • func (_ *UnionNullLong) SetBytes(v []byte)
  • func (_ *UnionNullLong) SetDefault(i int)
  • func (_ *UnionNullLong) SetDouble(v float64)
  • func (_ *UnionNullLong) SetFloat(v float32)
  • func (_ *UnionNullLong) SetInt(v int32)
  • func (r *UnionNullLong) SetLong(v int64)
  • func (_ *UnionNullLong) SetString(v string)
  • func (r *UnionNullLong) UnmarshalJSON(data []byte) error
• type UnionNullLongTypeEnum

Constants

const TimesAvroCRC64Fingerprint = "\x16\xe8\xc3\xdec`E."

Types

type Times

type Times struct {
	// The timestamp when this avro data is written. Useful for identifying the newest row of data sharing keys.
	AvroWriteTime int64 `json:"AvroWriteTime"`
	// This is set to true when the Avro data is recording a delete in the source data.
	AvroDeleted bool `json:"AvroDeleted"`

	NonRequiredDate *UnionNullLong `json:"nonRequiredDate"`

	RequiredDate int64 `json:"requiredDate"`
}

func DeserializeTimes

func DeserializeTimes(r io.Reader) (*Times, error)

func DeserializeTimesFromSchema

func DeserializeTimesFromSchema(r io.Reader, schema string) (*Times, error)

func NewTimes

func NewTimes() *Times

func (*Times) AppendArray

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

func (*Times) AppendMap

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

func (*Times) AvroCRC64Fingerprint

func (_ *Times) AvroCRC64Fingerprint() []byte

func (*Times) Finalize

func (_ *Times) Finalize()

func (*Times) Get

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

func (*Times) NullField

func (r *Times) NullField(i int)

func (*Times) Schema

func (r *Times) Schema() string

func (*Times) SchemaName

func (r *Times) SchemaName() string

func (*Times) Serialize

func (r *Times) Serialize(w io.Writer) error

func (*Times) SetBoolean

func (_ *Times) SetBoolean(v bool)

func (*Times) SetBytes

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

func (*Times) SetDefault

func (r *Times) SetDefault(i int)

func (*Times) SetDouble

func (_ *Times) SetDouble(v float64)

func (*Times) SetFloat

func (_ *Times) SetFloat(v float32)

func (*Times) SetInt

func (_ *Times) SetInt(v int32)

func (*Times) SetLong

func (_ *Times) SetLong(v int64)

func (*Times) SetString

func (_ *Times) SetString(v string)

func (*Times) SetUnionElem

func (_ *Times) SetUnionElem(v int64)

type UnionNullLong

type UnionNullLong struct {
	Null      *types.NullVal
	Long      int64
	UnionType UnionNullLongTypeEnum
}

func NewUnionNullLong

func NewUnionNullLong() *UnionNullLong

func (*UnionNullLong) AppendArray

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

func (*UnionNullLong) AppendMap

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

func (*UnionNullLong) Finalize

func (_ *UnionNullLong) Finalize()

func (*UnionNullLong) Get

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

func (*UnionNullLong) MarshalJSON

func (r *UnionNullLong) MarshalJSON() ([]byte, error)

func (*UnionNullLong) NullField

func (_ *UnionNullLong) NullField(i int)

func (*UnionNullLong) SetBoolean

func (_ *UnionNullLong) SetBoolean(v bool)

func (*UnionNullLong) SetBytes

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

func (*UnionNullLong) SetDefault

func (_ *UnionNullLong) SetDefault(i int)

func (*UnionNullLong) SetDouble

func (_ *UnionNullLong) SetDouble(v float64)

func (*UnionNullLong) SetFloat

func (_ *UnionNullLong) SetFloat(v float32)

func (*UnionNullLong) SetInt

func (_ *UnionNullLong) SetInt(v int32)

func (*UnionNullLong) SetLong

func (r *UnionNullLong) SetLong(v int64)

func (*UnionNullLong) SetString

func (_ *UnionNullLong) SetString(v string)

func (*UnionNullLong) UnmarshalJSON

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

type UnionNullLongTypeEnum

type UnionNullLongTypeEnum int

const (
	UnionNullLongTypeEnumLong UnionNullLongTypeEnum = 1
)