avro

package
v6.5.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 26, 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

View Source 
const DataAvroCRC64Fingerprint = "\xa5\xec\x1f\xf5k\x15\xc1!"
View Source 
const SampleAvroCRC64Fingerprint = "\xdf}\x93 \x19f\x18\n"
View Source 
const TraceAvroCRC64Fingerprint = "\x83<\x8e\xd5T\xfc\x8d\x94"
View Source 
const UUIDAvroCRC64Fingerprint = "\xfc\xa43\x98\xee\xe0p\xe2"

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) (*Data, error)

func DeserializeDataFromSchema 

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

func NewData 

func NewData() *Data

func (*Data) AppendArray 

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

func (*Data) AppendMap 

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

func (*Data) AvroCRC64Fingerprint 

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

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() (*Data, error)

type Sample 

type Sample struct {
	Header *UnionNullData

	Body *UnionNullData
}

GoGen test

func DeserializeSample 

func DeserializeSample(r io.Reader) (*Sample, error)

func DeserializeSampleFromSchema 

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

func NewSample 

func NewSample() *Sample

func (*Sample) AppendArray 

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

func (*Sample) AppendMap 

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

func (*Sample) AvroCRC64Fingerprint 

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

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() (*Sample, error)

type Trace 

type Trace struct {
	TraceId *UnionNullUUID
}

Trace

func DeserializeTrace 

func DeserializeTrace(r io.Reader) (*Trace, error)

func DeserializeTraceFromSchema 

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

func NewTrace 

func NewTrace() *Trace

func (*Trace) AppendArray 

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

func (*Trace) AppendMap 

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

func (*Trace) AvroCRC64Fingerprint 

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

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() (*Trace, 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) (*UUID, error)

func DeserializeUUIDFromSchema 

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

func NewUUID 

func NewUUID() *UUID

func (*UUID) AppendArray 

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

func (*UUID) AppendMap 

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

func (*UUID) AvroCRC64Fingerprint 

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

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() (*UUID, error)

type UnionNullData 

type UnionNullData struct {
	Null *types.NullVal

	Data *Data

	UnionType UnionNullDataTypeEnum
}

func NewUnionNullData 

func NewUnionNullData() *UnionNullData

func (*UnionNullData) AppendArray 

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

func (*UnionNullData) AppendMap 

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

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 (
	UnionNullDataTypeEnumNull UnionNullDataTypeEnum = 0

	UnionNullDataTypeEnumData UnionNullDataTypeEnum = 1
)

type UnionNullString 

type UnionNullString struct {
	Null *types.NullVal

	String string

	UnionType UnionNullStringTypeEnum
}

func NewUnionNullString 

func NewUnionNullString() *UnionNullString

func (*UnionNullString) AppendArray 

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

func (*UnionNullString) AppendMap 

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

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 (
	UnionNullStringTypeEnumNull UnionNullStringTypeEnum = 0

	UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)

type UnionNullTrace 

type UnionNullTrace struct {
	Null *types.NullVal

	Trace *Trace

	UnionType UnionNullTraceTypeEnum
}

func NewUnionNullTrace 

func NewUnionNullTrace() *UnionNullTrace

func (*UnionNullTrace) AppendArray 

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

func (*UnionNullTrace) AppendMap 

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

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 (
	UnionNullTraceTypeEnumNull UnionNullTraceTypeEnum = 0

	UnionNullTraceTypeEnumTrace UnionNullTraceTypeEnum = 1
)

type UnionNullUUID 

type UnionNullUUID struct {
	Null *types.NullVal

	UUID *UUID

	UnionType UnionNullUUIDTypeEnum
}

func NewUnionNullUUID 

func NewUnionNullUUID() *UnionNullUUID

func (*UnionNullUUID) AppendArray 

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

func (*UnionNullUUID) AppendMap 

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

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 (
	UnionNullUUIDTypeEnumNull UnionNullUUIDTypeEnum = 0

	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.