avro

package
v10.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: 6 Imported by: 0

Documentation

Overview

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

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

  • SOURCE:
  • namespace.avsc

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDataWriter 

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

func NewSampleWriter 

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

func NewTraceWriter 

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

func NewUUIDWriter 

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

Types

type Data 

type Data struct {
	Uuid *UnionNullUUID

	Hostname *UnionNullString

	Trace *UnionNullTrace
}

Common information related to the event which must be included in any clean event

func DeserializeData 

func DeserializeData(r io.Reader) (t Data, err error)

func DeserializeDataFromSchema 

func DeserializeDataFromSchema(r io.Reader, schema string) (t Data, err error)

func (*Data) AppendArray 

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

func (*Data) AppendMap 

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

func (*Data) Clear 

func (r *Data) Clear(i int)

func (*Data) Finalize 

func (_ *Data) Finalize()

func (*Data) Get 

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

func (Data) Schema 

func (r Data) Schema() string

func (Data) SchemaName 

func (r Data) SchemaName() string

func (Data) Serialize 

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

func (*Data) SetBoolean 

func (_ *Data) SetBoolean(v bool)

func (*Data) SetBytes 

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

func (*Data) SetDefault 

func (r *Data) SetDefault(i int)

func (*Data) SetDouble 

func (_ *Data) SetDouble(v float64)

func (*Data) SetFloat 

func (_ *Data) SetFloat(v float32)

func (*Data) SetInt 

func (_ *Data) SetInt(v int32)

func (*Data) SetLong 

func (_ *Data) SetLong(v int64)

func (*Data) SetString 

func (_ *Data) SetString(v string)

func (*Data) SetUnionElem 

func (_ *Data) SetUnionElem(v int64)

type DataReader 

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

container reader

func NewDataReader 

func NewDataReader(r io.Reader) (*DataReader, error)

func (DataReader) Read 

func (r DataReader) Read() (t Data, err error)

type Sample 

type Sample struct {
	Header *UnionNullData

	Body *UnionNullData
}

GoGen test

func DeserializeSample 

func DeserializeSample(r io.Reader) (t Sample, err error)

func DeserializeSampleFromSchema 

func DeserializeSampleFromSchema(r io.Reader, schema string) (t Sample, err error)

func (*Sample) AppendArray 

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

func (*Sample) AppendMap 

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

func (*Sample) Clear 

func (r *Sample) Clear(i int)

func (*Sample) Finalize 

func (_ *Sample) Finalize()

func (*Sample) Get 

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

func (Sample) Schema 

func (r Sample) Schema() string

func (Sample) SchemaName 

func (r Sample) SchemaName() string

func (Sample) Serialize 

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

func (*Sample) SetBoolean 

func (_ *Sample) SetBoolean(v bool)

func (*Sample) SetBytes 

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

func (*Sample) SetDefault 

func (r *Sample) SetDefault(i int)

func (*Sample) SetDouble 

func (_ *Sample) SetDouble(v float64)

func (*Sample) SetFloat 

func (_ *Sample) SetFloat(v float32)

func (*Sample) SetInt 

func (_ *Sample) SetInt(v int32)

func (*Sample) SetLong 

func (_ *Sample) SetLong(v int64)

func (*Sample) SetString 

func (_ *Sample) SetString(v string)

func (*Sample) SetUnionElem 

func (_ *Sample) SetUnionElem(v int64)

type SampleReader 

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

container reader

func NewSampleReader 

func NewSampleReader(r io.Reader) (*SampleReader, error)

func (SampleReader) Read 

func (r SampleReader) Read() (t Sample, err error)

type Trace 

type Trace struct {
	TraceId *UnionNullUUID
}

Trace

func DeserializeTrace 

func DeserializeTrace(r io.Reader) (t Trace, err error)

func DeserializeTraceFromSchema 

func DeserializeTraceFromSchema(r io.Reader, schema string) (t Trace, err error)

func (*Trace) AppendArray 

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

func (*Trace) AppendMap 

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

func (*Trace) Clear 

func (r *Trace) Clear(i int)

func (*Trace) Finalize 

func (_ *Trace) Finalize()

func (*Trace) Get 

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

func (Trace) Schema 

func (r Trace) Schema() string

func (Trace) SchemaName 

func (r Trace) SchemaName() string

func (Trace) Serialize 

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

func (*Trace) SetBoolean 

func (_ *Trace) SetBoolean(v bool)

func (*Trace) SetBytes 

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

func (*Trace) SetDefault 

func (r *Trace) SetDefault(i int)

func (*Trace) SetDouble 

func (_ *Trace) SetDouble(v float64)

func (*Trace) SetFloat 

func (_ *Trace) SetFloat(v float32)

func (*Trace) SetInt 

func (_ *Trace) SetInt(v int32)

func (*Trace) SetLong 

func (_ *Trace) SetLong(v int64)

func (*Trace) SetString 

func (_ *Trace) SetString(v string)

func (*Trace) SetUnionElem 

func (_ *Trace) SetUnionElem(v int64)

type TraceReader 

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

container reader

func NewTraceReader 

func NewTraceReader(r io.Reader) (*TraceReader, error)

func (TraceReader) Read 

func (r TraceReader) Read() (t Trace, err error)

type UUID 

type UUID struct {
	Uuid string
}

A Universally Unique Identifier, in canonical form in lowercase. Example: de305d54-75b4-431b-adb2-eb6b9e546014

func DeserializeUUID 

func DeserializeUUID(r io.Reader) (t UUID, err error)

func DeserializeUUIDFromSchema 

func DeserializeUUIDFromSchema(r io.Reader, schema string) (t UUID, err error)

func (*UUID) AppendArray 

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

func (*UUID) AppendMap 

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

func (*UUID) Clear 

func (r *UUID) Clear(i int)

func (*UUID) Finalize 

func (_ *UUID) Finalize()

func (*UUID) Get 

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

func (UUID) Schema 

func (r UUID) Schema() string

func (UUID) SchemaName 

func (r UUID) SchemaName() string

func (UUID) Serialize 

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

func (*UUID) SetBoolean 

func (_ *UUID) SetBoolean(v bool)

func (*UUID) SetBytes 

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

func (*UUID) SetDefault 

func (r *UUID) SetDefault(i int)

func (*UUID) SetDouble 

func (_ *UUID) SetDouble(v float64)

func (*UUID) SetFloat 

func (_ *UUID) SetFloat(v float32)

func (*UUID) SetInt 

func (_ *UUID) SetInt(v int32)

func (*UUID) SetLong 

func (_ *UUID) SetLong(v int64)

func (*UUID) SetString 

func (_ *UUID) SetString(v string)

func (*UUID) SetUnionElem 

func (_ *UUID) SetUnionElem(v int64)

type UUIDReader 

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

container reader

func NewUUIDReader 

func NewUUIDReader(r io.Reader) (*UUIDReader, error)

func (UUIDReader) Read 

func (r UUIDReader) Read() (t UUID, err error)

type UnionNullData 

type UnionNullData struct {
	Data Data

	UnionType UnionNullDataTypeEnum
}

func (*UnionNullData) AppendArray 

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

func (*UnionNullData) AppendMap 

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

func (*UnionNullData) Clear 

func (r *UnionNullData) Clear(i int)

func (*UnionNullData) Finalize 

func (_ *UnionNullData) Finalize()

func (*UnionNullData) Get 

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

func (*UnionNullData) SetBoolean 

func (_ *UnionNullData) SetBoolean(v bool)

func (*UnionNullData) SetBytes 

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

func (*UnionNullData) SetDefault 

func (_ *UnionNullData) SetDefault(i int)

func (*UnionNullData) SetDouble 

func (_ *UnionNullData) SetDouble(v float64)

func (*UnionNullData) SetFloat 

func (_ *UnionNullData) SetFloat(v float32)

func (*UnionNullData) SetInt 

func (_ *UnionNullData) SetInt(v int32)

func (*UnionNullData) SetLong 

func (r *UnionNullData) SetLong(v int64)

func (*UnionNullData) SetString 

func (_ *UnionNullData) SetString(v string)

type UnionNullDataTypeEnum 

type UnionNullDataTypeEnum int
const (
	UnionNullDataTypeEnumData UnionNullDataTypeEnum = 1
)

type UnionNullString 

type UnionNullString struct {
	String string

	UnionType UnionNullStringTypeEnum
}

func (*UnionNullString) AppendArray 

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

func (*UnionNullString) AppendMap 

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

func (*UnionNullString) Clear 

func (r *UnionNullString) Clear(i int)

func (*UnionNullString) Finalize 

func (_ *UnionNullString) Finalize()

func (*UnionNullString) Get 

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

func (*UnionNullString) SetBoolean 

func (_ *UnionNullString) SetBoolean(v bool)

func (*UnionNullString) SetBytes 

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

func (*UnionNullString) SetDefault 

func (_ *UnionNullString) SetDefault(i int)

func (*UnionNullString) SetDouble 

func (_ *UnionNullString) SetDouble(v float64)

func (*UnionNullString) SetFloat 

func (_ *UnionNullString) SetFloat(v float32)

func (*UnionNullString) SetInt 

func (_ *UnionNullString) SetInt(v int32)

func (*UnionNullString) SetLong 

func (r *UnionNullString) SetLong(v int64)

func (*UnionNullString) SetString 

func (_ *UnionNullString) SetString(v string)

type UnionNullStringTypeEnum 

type UnionNullStringTypeEnum int
const (
	UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)

type UnionNullTrace 

type UnionNullTrace struct {
	Trace Trace

	UnionType UnionNullTraceTypeEnum
}

func (*UnionNullTrace) AppendArray 

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

func (*UnionNullTrace) AppendMap 

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

func (*UnionNullTrace) Clear 

func (r *UnionNullTrace) Clear(i int)

func (*UnionNullTrace) Finalize 

func (_ *UnionNullTrace) Finalize()

func (*UnionNullTrace) Get 

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

func (*UnionNullTrace) SetBoolean 

func (_ *UnionNullTrace) SetBoolean(v bool)

func (*UnionNullTrace) SetBytes 

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

func (*UnionNullTrace) SetDefault 

func (_ *UnionNullTrace) SetDefault(i int)

func (*UnionNullTrace) SetDouble 

func (_ *UnionNullTrace) SetDouble(v float64)

func (*UnionNullTrace) SetFloat 

func (_ *UnionNullTrace) SetFloat(v float32)

func (*UnionNullTrace) SetInt 

func (_ *UnionNullTrace) SetInt(v int32)

func (*UnionNullTrace) SetLong 

func (r *UnionNullTrace) SetLong(v int64)

func (*UnionNullTrace) SetString 

func (_ *UnionNullTrace) SetString(v string)

type UnionNullTraceTypeEnum 

type UnionNullTraceTypeEnum int
const (
	UnionNullTraceTypeEnumTrace UnionNullTraceTypeEnum = 1
)

type UnionNullUUID 

type UnionNullUUID struct {
	UUID UUID

	UnionType UnionNullUUIDTypeEnum
}

func (*UnionNullUUID) AppendArray 

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

func (*UnionNullUUID) AppendMap 

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

func (*UnionNullUUID) Clear 

func (r *UnionNullUUID) Clear(i int)

func (*UnionNullUUID) Finalize 

func (_ *UnionNullUUID) Finalize()

func (*UnionNullUUID) Get 

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

func (*UnionNullUUID) SetBoolean 

func (_ *UnionNullUUID) SetBoolean(v bool)

func (*UnionNullUUID) SetBytes 

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

func (*UnionNullUUID) SetDefault 

func (_ *UnionNullUUID) SetDefault(i int)

func (*UnionNullUUID) SetDouble 

func (_ *UnionNullUUID) SetDouble(v float64)

func (*UnionNullUUID) SetFloat 

func (_ *UnionNullUUID) SetFloat(v float32)

func (*UnionNullUUID) SetInt 

func (_ *UnionNullUUID) SetInt(v int32)

func (*UnionNullUUID) SetLong 

func (r *UnionNullUUID) SetLong(v int64)

func (*UnionNullUUID) SetString 

func (_ *UnionNullUUID) SetString(v string)

type UnionNullUUIDTypeEnum 

type UnionNullUUIDTypeEnum int
const (
	UnionNullUUIDTypeEnumUUID UnionNullUUIDTypeEnum = 1
)

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.