avro

package

Go to main page

Versions in this module

v6

v6.5.0

Mar 26, 2020

Changes in this version

+ const BodyworksDataAvroCRC64Fingerprint

+ const BodyworksTraceAvroCRC64Fingerprint

+ const DatatypeUUIDAvroCRC64Fingerprint

+ const HeaderworksDataAvroCRC64Fingerprint

+ const HeaderworksTraceAvroCRC64Fingerprint

+ const TestSampleAvroCRC64Fingerprint

type BodyworksData

+ func (_ *BodyworksData) AvroCRC64Fingerprint() []byte

type BodyworksTrace

+ func (_ *BodyworksTrace) AvroCRC64Fingerprint() []byte

type DatatypeUUID

+ func (_ *DatatypeUUID) AvroCRC64Fingerprint() []byte

type HeaderworksData

+ func (_ *HeaderworksData) AvroCRC64Fingerprint() []byte

type HeaderworksTrace

+ func (_ *HeaderworksTrace) AvroCRC64Fingerprint() []byte

type TestSample

+ func (_ *TestSample) AvroCRC64Fingerprint() []byte

v6.4.0

Mar 9, 2020

Changes in this version

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

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

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

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

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

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

+ type BodyworksData struct

+ Hostname *UnionNullString

+ Trace *UnionNullBodyworksTrace

+ Uuid *UnionNullDatatypeUUID

+ func DeserializeBodyworksData(r io.Reader) (*BodyworksData, error)

+ func DeserializeBodyworksDataFromSchema(r io.Reader, schema string) (*BodyworksData, error)

+ func NewBodyworksData() *BodyworksData

+ func (_ *BodyworksData) AppendArray() types.Field

+ func (_ *BodyworksData) AppendMap(key string) types.Field

+ func (_ *BodyworksData) Finalize()

+ func (_ *BodyworksData) SetBoolean(v bool)

+ func (_ *BodyworksData) SetBytes(v []byte)

+ func (_ *BodyworksData) SetDouble(v float64)

+ func (_ *BodyworksData) SetFloat(v float32)

+ func (_ *BodyworksData) SetInt(v int32)

+ func (_ *BodyworksData) SetLong(v int64)

+ func (_ *BodyworksData) SetString(v string)

+ func (_ *BodyworksData) SetUnionElem(v int64)

+ func (r *BodyworksData) Get(i int) types.Field

+ func (r *BodyworksData) Schema() string

+ func (r *BodyworksData) SchemaName() string

+ func (r *BodyworksData) Serialize(w io.Writer) error

+ func (r *BodyworksData) SetDefault(i int)

+ type BodyworksDataReader struct

+ func NewBodyworksDataReader(r io.Reader) (*BodyworksDataReader, error)

+ func (r BodyworksDataReader) Read() (*BodyworksData, error)

+ type BodyworksTrace struct

+ TraceId *UnionNullDatatypeUUID

+ func DeserializeBodyworksTrace(r io.Reader) (*BodyworksTrace, error)

+ func DeserializeBodyworksTraceFromSchema(r io.Reader, schema string) (*BodyworksTrace, error)

+ func NewBodyworksTrace() *BodyworksTrace

+ func (_ *BodyworksTrace) AppendArray() types.Field

+ func (_ *BodyworksTrace) AppendMap(key string) types.Field

+ func (_ *BodyworksTrace) Finalize()

+ func (_ *BodyworksTrace) SetBoolean(v bool)

+ func (_ *BodyworksTrace) SetBytes(v []byte)

+ func (_ *BodyworksTrace) SetDouble(v float64)

+ func (_ *BodyworksTrace) SetFloat(v float32)

+ func (_ *BodyworksTrace) SetInt(v int32)

+ func (_ *BodyworksTrace) SetLong(v int64)

+ func (_ *BodyworksTrace) SetString(v string)

+ func (_ *BodyworksTrace) SetUnionElem(v int64)

+ func (r *BodyworksTrace) Get(i int) types.Field

+ func (r *BodyworksTrace) Schema() string

+ func (r *BodyworksTrace) SchemaName() string

+ func (r *BodyworksTrace) Serialize(w io.Writer) error

+ func (r *BodyworksTrace) SetDefault(i int)

+ type BodyworksTraceReader struct

+ func NewBodyworksTraceReader(r io.Reader) (*BodyworksTraceReader, error)

+ func (r BodyworksTraceReader) Read() (*BodyworksTrace, error)

+ type DatatypeUUID struct

+ Uuid string

+ func DeserializeDatatypeUUID(r io.Reader) (*DatatypeUUID, error)

+ func DeserializeDatatypeUUIDFromSchema(r io.Reader, schema string) (*DatatypeUUID, error)

+ func NewDatatypeUUID() *DatatypeUUID

+ func (_ *DatatypeUUID) AppendArray() types.Field

+ func (_ *DatatypeUUID) AppendMap(key string) types.Field

+ func (_ *DatatypeUUID) Finalize()

+ func (_ *DatatypeUUID) SetBoolean(v bool)

+ func (_ *DatatypeUUID) SetBytes(v []byte)

+ func (_ *DatatypeUUID) SetDouble(v float64)

+ func (_ *DatatypeUUID) SetFloat(v float32)

+ func (_ *DatatypeUUID) SetInt(v int32)

+ func (_ *DatatypeUUID) SetLong(v int64)

+ func (_ *DatatypeUUID) SetString(v string)

+ func (_ *DatatypeUUID) SetUnionElem(v int64)

+ func (r *DatatypeUUID) Get(i int) types.Field

+ func (r *DatatypeUUID) Schema() string

+ func (r *DatatypeUUID) SchemaName() string

+ func (r *DatatypeUUID) Serialize(w io.Writer) error

+ func (r *DatatypeUUID) SetDefault(i int)

+ type DatatypeUUIDReader struct

+ func NewDatatypeUUIDReader(r io.Reader) (*DatatypeUUIDReader, error)

+ func (r DatatypeUUIDReader) Read() (*DatatypeUUID, error)

+ type HeaderworksData struct

+ Hostname *UnionNullString

+ Trace *UnionNullHeaderworksTrace

+ Uuid *UnionNullDatatypeUUID

+ func DeserializeHeaderworksData(r io.Reader) (*HeaderworksData, error)

+ func DeserializeHeaderworksDataFromSchema(r io.Reader, schema string) (*HeaderworksData, error)

+ func NewHeaderworksData() *HeaderworksData

+ func (_ *HeaderworksData) AppendArray() types.Field

+ func (_ *HeaderworksData) AppendMap(key string) types.Field

+ func (_ *HeaderworksData) Finalize()

+ func (_ *HeaderworksData) SetBoolean(v bool)

+ func (_ *HeaderworksData) SetBytes(v []byte)

+ func (_ *HeaderworksData) SetDouble(v float64)

+ func (_ *HeaderworksData) SetFloat(v float32)

+ func (_ *HeaderworksData) SetInt(v int32)

+ func (_ *HeaderworksData) SetLong(v int64)

+ func (_ *HeaderworksData) SetString(v string)

+ func (_ *HeaderworksData) SetUnionElem(v int64)

+ func (r *HeaderworksData) Get(i int) types.Field

+ func (r *HeaderworksData) Schema() string

+ func (r *HeaderworksData) SchemaName() string

+ func (r *HeaderworksData) Serialize(w io.Writer) error

+ func (r *HeaderworksData) SetDefault(i int)

+ type HeaderworksDataReader struct

+ func NewHeaderworksDataReader(r io.Reader) (*HeaderworksDataReader, error)

+ func (r HeaderworksDataReader) Read() (*HeaderworksData, error)

+ type HeaderworksTrace struct

+ TraceId *UnionNullDatatypeUUID

+ func DeserializeHeaderworksTrace(r io.Reader) (*HeaderworksTrace, error)

+ func DeserializeHeaderworksTraceFromSchema(r io.Reader, schema string) (*HeaderworksTrace, error)

+ func NewHeaderworksTrace() *HeaderworksTrace

+ func (_ *HeaderworksTrace) AppendArray() types.Field

+ func (_ *HeaderworksTrace) AppendMap(key string) types.Field

+ func (_ *HeaderworksTrace) Finalize()

+ func (_ *HeaderworksTrace) SetBoolean(v bool)

+ func (_ *HeaderworksTrace) SetBytes(v []byte)

+ func (_ *HeaderworksTrace) SetDouble(v float64)

+ func (_ *HeaderworksTrace) SetFloat(v float32)

+ func (_ *HeaderworksTrace) SetInt(v int32)

+ func (_ *HeaderworksTrace) SetLong(v int64)

+ func (_ *HeaderworksTrace) SetString(v string)

+ func (_ *HeaderworksTrace) SetUnionElem(v int64)

+ func (r *HeaderworksTrace) Get(i int) types.Field

+ func (r *HeaderworksTrace) Schema() string

+ func (r *HeaderworksTrace) SchemaName() string

+ func (r *HeaderworksTrace) Serialize(w io.Writer) error

+ func (r *HeaderworksTrace) SetDefault(i int)

+ type HeaderworksTraceReader struct

+ func NewHeaderworksTraceReader(r io.Reader) (*HeaderworksTraceReader, error)

+ func (r HeaderworksTraceReader) Read() (*HeaderworksTrace, error)

+ type TestSample struct

+ Body *UnionNullBodyworksData

+ Header *UnionNullHeaderworksData

+ func DeserializeTestSample(r io.Reader) (*TestSample, error)

+ func DeserializeTestSampleFromSchema(r io.Reader, schema string) (*TestSample, error)

+ func NewTestSample() *TestSample

+ func (_ *TestSample) AppendArray() types.Field

+ func (_ *TestSample) AppendMap(key string) types.Field

+ func (_ *TestSample) Finalize()

+ func (_ *TestSample) SetBoolean(v bool)

+ func (_ *TestSample) SetBytes(v []byte)

+ func (_ *TestSample) SetDouble(v float64)

+ func (_ *TestSample) SetFloat(v float32)

+ func (_ *TestSample) SetInt(v int32)

+ func (_ *TestSample) SetLong(v int64)

+ func (_ *TestSample) SetString(v string)

+ func (_ *TestSample) SetUnionElem(v int64)

+ func (r *TestSample) Get(i int) types.Field

+ func (r *TestSample) Schema() string

+ func (r *TestSample) SchemaName() string

+ func (r *TestSample) Serialize(w io.Writer) error

+ func (r *TestSample) SetDefault(i int)

+ type TestSampleReader struct

+ func NewTestSampleReader(r io.Reader) (*TestSampleReader, error)

+ func (r TestSampleReader) Read() (*TestSample, error)

+ type UnionNullBodyworksData struct

+ BodyworksData *BodyworksData

+ Null *types.NullVal

+ UnionType UnionNullBodyworksDataTypeEnum

+ func NewUnionNullBodyworksData() *UnionNullBodyworksData

+ func (_ *UnionNullBodyworksData) AppendArray() types.Field

+ func (_ *UnionNullBodyworksData) AppendMap(key string) types.Field

+ func (_ *UnionNullBodyworksData) Finalize()

+ func (_ *UnionNullBodyworksData) SetBoolean(v bool)

+ func (_ *UnionNullBodyworksData) SetBytes(v []byte)

+ func (_ *UnionNullBodyworksData) SetDefault(i int)

+ func (_ *UnionNullBodyworksData) SetDouble(v float64)

+ func (_ *UnionNullBodyworksData) SetFloat(v float32)

+ func (_ *UnionNullBodyworksData) SetInt(v int32)

+ func (_ *UnionNullBodyworksData) SetString(v string)

+ func (r *UnionNullBodyworksData) Get(i int) types.Field

+ func (r *UnionNullBodyworksData) SetLong(v int64)

+ type UnionNullBodyworksDataTypeEnum int

+ const UnionNullBodyworksDataTypeEnumBodyworksData

+ const UnionNullBodyworksDataTypeEnumNull

+ type UnionNullBodyworksTrace struct

+ BodyworksTrace *BodyworksTrace

+ Null *types.NullVal

+ UnionType UnionNullBodyworksTraceTypeEnum

+ func NewUnionNullBodyworksTrace() *UnionNullBodyworksTrace

+ func (_ *UnionNullBodyworksTrace) AppendArray() types.Field

+ func (_ *UnionNullBodyworksTrace) AppendMap(key string) types.Field

+ func (_ *UnionNullBodyworksTrace) Finalize()

+ func (_ *UnionNullBodyworksTrace) SetBoolean(v bool)

+ func (_ *UnionNullBodyworksTrace) SetBytes(v []byte)

+ func (_ *UnionNullBodyworksTrace) SetDefault(i int)

+ func (_ *UnionNullBodyworksTrace) SetDouble(v float64)

+ func (_ *UnionNullBodyworksTrace) SetFloat(v float32)

+ func (_ *UnionNullBodyworksTrace) SetInt(v int32)

+ func (_ *UnionNullBodyworksTrace) SetString(v string)

+ func (r *UnionNullBodyworksTrace) Get(i int) types.Field

+ func (r *UnionNullBodyworksTrace) SetLong(v int64)

+ type UnionNullBodyworksTraceTypeEnum int

+ const UnionNullBodyworksTraceTypeEnumBodyworksTrace

+ const UnionNullBodyworksTraceTypeEnumNull

+ type UnionNullDatatypeUUID struct

+ DatatypeUUID *DatatypeUUID

+ Null *types.NullVal

+ UnionType UnionNullDatatypeUUIDTypeEnum

+ func NewUnionNullDatatypeUUID() *UnionNullDatatypeUUID

+ func (_ *UnionNullDatatypeUUID) AppendArray() types.Field

+ func (_ *UnionNullDatatypeUUID) AppendMap(key string) types.Field

+ func (_ *UnionNullDatatypeUUID) Finalize()

+ func (_ *UnionNullDatatypeUUID) SetBoolean(v bool)

+ func (_ *UnionNullDatatypeUUID) SetBytes(v []byte)

+ func (_ *UnionNullDatatypeUUID) SetDefault(i int)

+ func (_ *UnionNullDatatypeUUID) SetDouble(v float64)

+ func (_ *UnionNullDatatypeUUID) SetFloat(v float32)

+ func (_ *UnionNullDatatypeUUID) SetInt(v int32)

+ func (_ *UnionNullDatatypeUUID) SetString(v string)

+ func (r *UnionNullDatatypeUUID) Get(i int) types.Field

+ func (r *UnionNullDatatypeUUID) SetLong(v int64)

+ type UnionNullDatatypeUUIDTypeEnum int

+ const UnionNullDatatypeUUIDTypeEnumDatatypeUUID

+ const UnionNullDatatypeUUIDTypeEnumNull

+ type UnionNullHeaderworksData struct

+ HeaderworksData *HeaderworksData

+ Null *types.NullVal

+ UnionType UnionNullHeaderworksDataTypeEnum

+ func NewUnionNullHeaderworksData() *UnionNullHeaderworksData

+ func (_ *UnionNullHeaderworksData) AppendArray() types.Field

+ func (_ *UnionNullHeaderworksData) AppendMap(key string) types.Field

+ func (_ *UnionNullHeaderworksData) Finalize()

+ func (_ *UnionNullHeaderworksData) SetBoolean(v bool)

+ func (_ *UnionNullHeaderworksData) SetBytes(v []byte)

+ func (_ *UnionNullHeaderworksData) SetDefault(i int)

+ func (_ *UnionNullHeaderworksData) SetDouble(v float64)

+ func (_ *UnionNullHeaderworksData) SetFloat(v float32)

+ func (_ *UnionNullHeaderworksData) SetInt(v int32)

+ func (_ *UnionNullHeaderworksData) SetString(v string)

+ func (r *UnionNullHeaderworksData) Get(i int) types.Field

+ func (r *UnionNullHeaderworksData) SetLong(v int64)

+ type UnionNullHeaderworksDataTypeEnum int

+ const UnionNullHeaderworksDataTypeEnumHeaderworksData

+ const UnionNullHeaderworksDataTypeEnumNull

+ type UnionNullHeaderworksTrace struct

+ HeaderworksTrace *HeaderworksTrace

+ Null *types.NullVal

+ UnionType UnionNullHeaderworksTraceTypeEnum

+ func NewUnionNullHeaderworksTrace() *UnionNullHeaderworksTrace

+ func (_ *UnionNullHeaderworksTrace) AppendArray() types.Field

+ func (_ *UnionNullHeaderworksTrace) AppendMap(key string) types.Field

+ func (_ *UnionNullHeaderworksTrace) Finalize()

+ func (_ *UnionNullHeaderworksTrace) SetBoolean(v bool)

+ func (_ *UnionNullHeaderworksTrace) SetBytes(v []byte)

+ func (_ *UnionNullHeaderworksTrace) SetDefault(i int)

+ func (_ *UnionNullHeaderworksTrace) SetDouble(v float64)

+ func (_ *UnionNullHeaderworksTrace) SetFloat(v float32)

+ func (_ *UnionNullHeaderworksTrace) SetInt(v int32)

+ func (_ *UnionNullHeaderworksTrace) SetString(v string)

+ func (r *UnionNullHeaderworksTrace) Get(i int) types.Field

+ func (r *UnionNullHeaderworksTrace) SetLong(v int64)

+ type UnionNullHeaderworksTraceTypeEnum int

+ const UnionNullHeaderworksTraceTypeEnumHeaderworksTrace

+ const UnionNullHeaderworksTraceTypeEnumNull

+ type UnionNullString struct

+ Null *types.NullVal

+ String string

+ UnionType UnionNullStringTypeEnum

+ func NewUnionNullString() *UnionNullString

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

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

+ func (_ *UnionNullString) Finalize()

+ func (_ *UnionNullString) SetBoolean(v bool)

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

+ func (_ *UnionNullString) SetDefault(i int)

+ func (_ *UnionNullString) SetDouble(v float64)

+ func (_ *UnionNullString) SetFloat(v float32)

+ func (_ *UnionNullString) SetInt(v int32)

+ func (_ *UnionNullString) SetString(v string)

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

+ func (r *UnionNullString) SetLong(v int64)

+ type UnionNullStringTypeEnum int

+ const UnionNullStringTypeEnumNull

+ const UnionNullStringTypeEnumString

v6.3.1

Dec 1, 2019

v6.3.1-wip-refactoring

Mar 3, 2020

v6.3.0

Nov 21, 2019

v6.2.0

Sep 21, 2019

v6.1.1

Sep 18, 2019

v6.1.0

Jul 13, 2019

v6.0.0

Jun 12, 2019

Other modules containing this package

gopkg.in/alanctgardner/gogen-avro.v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL