Documentation ¶
Overview ¶
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- namespace.avsc
Index ¶
- Constants
- 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
- func (_ *BodyworksData) AppendArray() types.Field
- func (_ *BodyworksData) AppendMap(key string) types.Field
- func (_ *BodyworksData) AvroCRC64Fingerprint() []byte
- func (_ *BodyworksData) Finalize()
- func (r *BodyworksData) Get(i int) types.Field
- func (r *BodyworksData) NullField(i int)
- func (r *BodyworksData) Schema() string
- func (r *BodyworksData) SchemaName() string
- func (r *BodyworksData) Serialize(w io.Writer) error
- func (_ *BodyworksData) SetBoolean(v bool)
- func (_ *BodyworksData) SetBytes(v []byte)
- func (r *BodyworksData) SetDefault(i int)
- 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)
- type BodyworksDataReader
- type BodyworksTrace
- func (_ *BodyworksTrace) AppendArray() types.Field
- func (_ *BodyworksTrace) AppendMap(key string) types.Field
- func (_ *BodyworksTrace) AvroCRC64Fingerprint() []byte
- func (_ *BodyworksTrace) Finalize()
- func (r *BodyworksTrace) Get(i int) types.Field
- func (r *BodyworksTrace) NullField(i int)
- func (r *BodyworksTrace) Schema() string
- func (r *BodyworksTrace) SchemaName() string
- func (r *BodyworksTrace) Serialize(w io.Writer) error
- func (_ *BodyworksTrace) SetBoolean(v bool)
- func (_ *BodyworksTrace) SetBytes(v []byte)
- func (r *BodyworksTrace) SetDefault(i int)
- 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)
- type BodyworksTraceReader
- type DatatypeUUID
- func (_ *DatatypeUUID) AppendArray() types.Field
- func (_ *DatatypeUUID) AppendMap(key string) types.Field
- func (_ *DatatypeUUID) AvroCRC64Fingerprint() []byte
- func (_ *DatatypeUUID) Finalize()
- func (r *DatatypeUUID) Get(i int) types.Field
- func (r *DatatypeUUID) NullField(i int)
- func (r *DatatypeUUID) Schema() string
- func (r *DatatypeUUID) SchemaName() string
- func (r *DatatypeUUID) Serialize(w io.Writer) error
- func (_ *DatatypeUUID) SetBoolean(v bool)
- func (_ *DatatypeUUID) SetBytes(v []byte)
- func (r *DatatypeUUID) SetDefault(i int)
- 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)
- type DatatypeUUIDReader
- type HeaderworksData
- func (_ *HeaderworksData) AppendArray() types.Field
- func (_ *HeaderworksData) AppendMap(key string) types.Field
- func (_ *HeaderworksData) AvroCRC64Fingerprint() []byte
- func (_ *HeaderworksData) Finalize()
- func (r *HeaderworksData) Get(i int) types.Field
- func (r *HeaderworksData) NullField(i int)
- func (r *HeaderworksData) Schema() string
- func (r *HeaderworksData) SchemaName() string
- func (r *HeaderworksData) Serialize(w io.Writer) error
- func (_ *HeaderworksData) SetBoolean(v bool)
- func (_ *HeaderworksData) SetBytes(v []byte)
- func (r *HeaderworksData) SetDefault(i int)
- 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)
- type HeaderworksDataReader
- type HeaderworksTrace
- func (_ *HeaderworksTrace) AppendArray() types.Field
- func (_ *HeaderworksTrace) AppendMap(key string) types.Field
- func (_ *HeaderworksTrace) AvroCRC64Fingerprint() []byte
- func (_ *HeaderworksTrace) Finalize()
- func (r *HeaderworksTrace) Get(i int) types.Field
- func (r *HeaderworksTrace) NullField(i int)
- func (r *HeaderworksTrace) Schema() string
- func (r *HeaderworksTrace) SchemaName() string
- func (r *HeaderworksTrace) Serialize(w io.Writer) error
- func (_ *HeaderworksTrace) SetBoolean(v bool)
- func (_ *HeaderworksTrace) SetBytes(v []byte)
- func (r *HeaderworksTrace) SetDefault(i int)
- 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)
- type HeaderworksTraceReader
- type TestSample
- func (_ *TestSample) AppendArray() types.Field
- func (_ *TestSample) AppendMap(key string) types.Field
- func (_ *TestSample) AvroCRC64Fingerprint() []byte
- func (_ *TestSample) Finalize()
- func (r *TestSample) Get(i int) types.Field
- func (r *TestSample) NullField(i int)
- func (r *TestSample) Schema() string
- func (r *TestSample) SchemaName() string
- func (r *TestSample) Serialize(w io.Writer) error
- func (_ *TestSample) SetBoolean(v bool)
- func (_ *TestSample) SetBytes(v []byte)
- func (r *TestSample) SetDefault(i int)
- 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)
- type TestSampleReader
- type UnionNullBodyworksData
- func (_ *UnionNullBodyworksData) AppendArray() types.Field
- func (_ *UnionNullBodyworksData) AppendMap(key string) types.Field
- func (_ *UnionNullBodyworksData) Finalize()
- func (r *UnionNullBodyworksData) Get(i int) types.Field
- func (r *UnionNullBodyworksData) MarshalJSON() ([]byte, error)
- func (_ *UnionNullBodyworksData) NullField(i int)
- 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 (r *UnionNullBodyworksData) SetLong(v int64)
- func (_ *UnionNullBodyworksData) SetString(v string)
- func (r *UnionNullBodyworksData) UnmarshalJSON(data []byte) error
- type UnionNullBodyworksDataTypeEnum
- type UnionNullBodyworksTrace
- func (_ *UnionNullBodyworksTrace) AppendArray() types.Field
- func (_ *UnionNullBodyworksTrace) AppendMap(key string) types.Field
- func (_ *UnionNullBodyworksTrace) Finalize()
- func (r *UnionNullBodyworksTrace) Get(i int) types.Field
- func (r *UnionNullBodyworksTrace) MarshalJSON() ([]byte, error)
- func (_ *UnionNullBodyworksTrace) NullField(i int)
- 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 (r *UnionNullBodyworksTrace) SetLong(v int64)
- func (_ *UnionNullBodyworksTrace) SetString(v string)
- func (r *UnionNullBodyworksTrace) UnmarshalJSON(data []byte) error
- type UnionNullBodyworksTraceTypeEnum
- type UnionNullDatatypeUUID
- func (_ *UnionNullDatatypeUUID) AppendArray() types.Field
- func (_ *UnionNullDatatypeUUID) AppendMap(key string) types.Field
- func (_ *UnionNullDatatypeUUID) Finalize()
- func (r *UnionNullDatatypeUUID) Get(i int) types.Field
- func (r *UnionNullDatatypeUUID) MarshalJSON() ([]byte, error)
- func (_ *UnionNullDatatypeUUID) NullField(i int)
- 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 (r *UnionNullDatatypeUUID) SetLong(v int64)
- func (_ *UnionNullDatatypeUUID) SetString(v string)
- func (r *UnionNullDatatypeUUID) UnmarshalJSON(data []byte) error
- type UnionNullDatatypeUUIDTypeEnum
- type UnionNullHeaderworksData
- func (_ *UnionNullHeaderworksData) AppendArray() types.Field
- func (_ *UnionNullHeaderworksData) AppendMap(key string) types.Field
- func (_ *UnionNullHeaderworksData) Finalize()
- func (r *UnionNullHeaderworksData) Get(i int) types.Field
- func (r *UnionNullHeaderworksData) MarshalJSON() ([]byte, error)
- func (_ *UnionNullHeaderworksData) NullField(i int)
- 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 (r *UnionNullHeaderworksData) SetLong(v int64)
- func (_ *UnionNullHeaderworksData) SetString(v string)
- func (r *UnionNullHeaderworksData) UnmarshalJSON(data []byte) error
- type UnionNullHeaderworksDataTypeEnum
- type UnionNullHeaderworksTrace
- func (_ *UnionNullHeaderworksTrace) AppendArray() types.Field
- func (_ *UnionNullHeaderworksTrace) AppendMap(key string) types.Field
- func (_ *UnionNullHeaderworksTrace) Finalize()
- func (r *UnionNullHeaderworksTrace) Get(i int) types.Field
- func (r *UnionNullHeaderworksTrace) MarshalJSON() ([]byte, error)
- func (_ *UnionNullHeaderworksTrace) NullField(i int)
- 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 (r *UnionNullHeaderworksTrace) SetLong(v int64)
- func (_ *UnionNullHeaderworksTrace) SetString(v string)
- func (r *UnionNullHeaderworksTrace) UnmarshalJSON(data []byte) error
- type UnionNullHeaderworksTraceTypeEnum
- type UnionNullString
- func (_ *UnionNullString) AppendArray() types.Field
- func (_ *UnionNullString) AppendMap(key string) types.Field
- func (_ *UnionNullString) Finalize()
- func (r *UnionNullString) Get(i int) types.Field
- func (r *UnionNullString) MarshalJSON() ([]byte, error)
- func (_ *UnionNullString) NullField(i int)
- 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 (r *UnionNullString) SetLong(v int64)
- func (_ *UnionNullString) SetString(v string)
- func (r *UnionNullString) UnmarshalJSON(data []byte) error
- type UnionNullStringTypeEnum
Constants ¶
const BodyworksDataAvroCRC64Fingerprint = "\xa5\xec\x1f\xf5k\x15\xc1!"
const BodyworksTraceAvroCRC64Fingerprint = "\x83<\x8e\xd5T\xfc\x8d\x94"
const DatatypeUUIDAvroCRC64Fingerprint = "\xfc\xa43\x98\xee\xe0p\xe2"
const HeaderworksDataAvroCRC64Fingerprint = "6<\xf6?EE\xcd\v"
const HeaderworksTraceAvroCRC64Fingerprint = "\x8a\xdfu\xe7˻\xa6\xbc"
const TestSampleAvroCRC64Fingerprint = "\xdf}\x93 \x19f\x18\n"
Variables ¶
This section is empty.
Functions ¶
func NewBodyworksDataWriter ¶
func NewBodyworksTraceWriter ¶
func NewDatatypeUUIDWriter ¶
Types ¶
type BodyworksData ¶
type BodyworksData struct { // Unique identifier for the event used for de-duplication and tracing. Uuid *UnionNullDatatypeUUID `json:"uuid"` // Fully qualified name of the host that generated the event that generated the data. Hostname *UnionNullString `json:"hostname"` // Trace information not redundant with this object Trace *UnionNullBodyworksTrace `json:"trace"` }
Common information related to the event which must be included in any clean event
func DeserializeBodyworksData ¶
func DeserializeBodyworksData(r io.Reader) (*BodyworksData, error)
func DeserializeBodyworksDataFromSchema ¶
func DeserializeBodyworksDataFromSchema(r io.Reader, schema string) (*BodyworksData, error)
func NewBodyworksData ¶
func NewBodyworksData() *BodyworksData
func (*BodyworksData) AppendArray ¶
func (_ *BodyworksData) AppendArray() types.Field
func (*BodyworksData) AvroCRC64Fingerprint ¶
func (_ *BodyworksData) AvroCRC64Fingerprint() []byte
func (*BodyworksData) Finalize ¶
func (_ *BodyworksData) Finalize()
func (*BodyworksData) NullField ¶
func (r *BodyworksData) NullField(i int)
func (*BodyworksData) Schema ¶
func (r *BodyworksData) Schema() string
func (*BodyworksData) SchemaName ¶
func (r *BodyworksData) SchemaName() string
func (*BodyworksData) SetBoolean ¶
func (_ *BodyworksData) SetBoolean(v bool)
func (*BodyworksData) SetBytes ¶
func (_ *BodyworksData) SetBytes(v []byte)
func (*BodyworksData) SetDefault ¶
func (r *BodyworksData) SetDefault(i int)
func (*BodyworksData) SetDouble ¶
func (_ *BodyworksData) SetDouble(v float64)
func (*BodyworksData) SetFloat ¶
func (_ *BodyworksData) SetFloat(v float32)
func (*BodyworksData) SetInt ¶
func (_ *BodyworksData) SetInt(v int32)
func (*BodyworksData) SetLong ¶
func (_ *BodyworksData) SetLong(v int64)
func (*BodyworksData) SetString ¶
func (_ *BodyworksData) SetString(v string)
func (*BodyworksData) SetUnionElem ¶
func (_ *BodyworksData) SetUnionElem(v int64)
type BodyworksDataReader ¶
type BodyworksDataReader struct {
// contains filtered or unexported fields
}
container reader
func NewBodyworksDataReader ¶
func NewBodyworksDataReader(r io.Reader) (*BodyworksDataReader, error)
func (BodyworksDataReader) Read ¶
func (r BodyworksDataReader) Read() (*BodyworksData, error)
type BodyworksTrace ¶
type BodyworksTrace struct { // Trace Identifier TraceId *UnionNullDatatypeUUID `json:"traceId"` }
Trace
func DeserializeBodyworksTrace ¶
func DeserializeBodyworksTrace(r io.Reader) (*BodyworksTrace, error)
func DeserializeBodyworksTraceFromSchema ¶
func DeserializeBodyworksTraceFromSchema(r io.Reader, schema string) (*BodyworksTrace, error)
func NewBodyworksTrace ¶
func NewBodyworksTrace() *BodyworksTrace
func (*BodyworksTrace) AppendArray ¶
func (_ *BodyworksTrace) AppendArray() types.Field
func (*BodyworksTrace) AvroCRC64Fingerprint ¶
func (_ *BodyworksTrace) AvroCRC64Fingerprint() []byte
func (*BodyworksTrace) Finalize ¶
func (_ *BodyworksTrace) Finalize()
func (*BodyworksTrace) NullField ¶
func (r *BodyworksTrace) NullField(i int)
func (*BodyworksTrace) Schema ¶
func (r *BodyworksTrace) Schema() string
func (*BodyworksTrace) SchemaName ¶
func (r *BodyworksTrace) SchemaName() string
func (*BodyworksTrace) SetBoolean ¶
func (_ *BodyworksTrace) SetBoolean(v bool)
func (*BodyworksTrace) SetBytes ¶
func (_ *BodyworksTrace) SetBytes(v []byte)
func (*BodyworksTrace) SetDefault ¶
func (r *BodyworksTrace) SetDefault(i int)
func (*BodyworksTrace) SetDouble ¶
func (_ *BodyworksTrace) SetDouble(v float64)
func (*BodyworksTrace) SetFloat ¶
func (_ *BodyworksTrace) SetFloat(v float32)
func (*BodyworksTrace) SetInt ¶
func (_ *BodyworksTrace) SetInt(v int32)
func (*BodyworksTrace) SetLong ¶
func (_ *BodyworksTrace) SetLong(v int64)
func (*BodyworksTrace) SetString ¶
func (_ *BodyworksTrace) SetString(v string)
func (*BodyworksTrace) SetUnionElem ¶
func (_ *BodyworksTrace) SetUnionElem(v int64)
type BodyworksTraceReader ¶
type BodyworksTraceReader struct {
// contains filtered or unexported fields
}
container reader
func NewBodyworksTraceReader ¶
func NewBodyworksTraceReader(r io.Reader) (*BodyworksTraceReader, error)
func (BodyworksTraceReader) Read ¶
func (r BodyworksTraceReader) Read() (*BodyworksTrace, error)
type DatatypeUUID ¶
type DatatypeUUID struct {
Uuid string `json:"uuid"`
}
A Universally Unique Identifier, in canonical form in lowercase. Example: de305d54-75b4-431b-adb2-eb6b9e546014
func DeserializeDatatypeUUID ¶
func DeserializeDatatypeUUID(r io.Reader) (*DatatypeUUID, error)
func DeserializeDatatypeUUIDFromSchema ¶
func DeserializeDatatypeUUIDFromSchema(r io.Reader, schema string) (*DatatypeUUID, error)
func NewDatatypeUUID ¶
func NewDatatypeUUID() *DatatypeUUID
func (*DatatypeUUID) AppendArray ¶
func (_ *DatatypeUUID) AppendArray() types.Field
func (*DatatypeUUID) AvroCRC64Fingerprint ¶
func (_ *DatatypeUUID) AvroCRC64Fingerprint() []byte
func (*DatatypeUUID) Finalize ¶
func (_ *DatatypeUUID) Finalize()
func (*DatatypeUUID) NullField ¶
func (r *DatatypeUUID) NullField(i int)
func (*DatatypeUUID) Schema ¶
func (r *DatatypeUUID) Schema() string
func (*DatatypeUUID) SchemaName ¶
func (r *DatatypeUUID) SchemaName() string
func (*DatatypeUUID) SetBoolean ¶
func (_ *DatatypeUUID) SetBoolean(v bool)
func (*DatatypeUUID) SetBytes ¶
func (_ *DatatypeUUID) SetBytes(v []byte)
func (*DatatypeUUID) SetDefault ¶
func (r *DatatypeUUID) SetDefault(i int)
func (*DatatypeUUID) SetDouble ¶
func (_ *DatatypeUUID) SetDouble(v float64)
func (*DatatypeUUID) SetFloat ¶
func (_ *DatatypeUUID) SetFloat(v float32)
func (*DatatypeUUID) SetInt ¶
func (_ *DatatypeUUID) SetInt(v int32)
func (*DatatypeUUID) SetLong ¶
func (_ *DatatypeUUID) SetLong(v int64)
func (*DatatypeUUID) SetString ¶
func (_ *DatatypeUUID) SetString(v string)
func (*DatatypeUUID) SetUnionElem ¶
func (_ *DatatypeUUID) SetUnionElem(v int64)
type DatatypeUUIDReader ¶
type DatatypeUUIDReader struct {
// contains filtered or unexported fields
}
container reader
func NewDatatypeUUIDReader ¶
func NewDatatypeUUIDReader(r io.Reader) (*DatatypeUUIDReader, error)
func (DatatypeUUIDReader) Read ¶
func (r DatatypeUUIDReader) Read() (*DatatypeUUID, error)
type HeaderworksData ¶
type HeaderworksData struct { // Unique identifier for the event used for de-duplication and tracing. Uuid *UnionNullDatatypeUUID `json:"uuid"` // Fully qualified name of the host that generated the event that generated the data. Hostname *UnionNullString `json:"hostname"` // Trace information not redundant with this object Trace *UnionNullHeaderworksTrace `json:"trace"` }
Common information related to the event which must be included in any clean event
func DeserializeHeaderworksData ¶
func DeserializeHeaderworksData(r io.Reader) (*HeaderworksData, error)
func DeserializeHeaderworksDataFromSchema ¶
func DeserializeHeaderworksDataFromSchema(r io.Reader, schema string) (*HeaderworksData, error)
func NewHeaderworksData ¶
func NewHeaderworksData() *HeaderworksData
func (*HeaderworksData) AppendArray ¶
func (_ *HeaderworksData) AppendArray() types.Field
func (*HeaderworksData) AvroCRC64Fingerprint ¶
func (_ *HeaderworksData) AvroCRC64Fingerprint() []byte
func (*HeaderworksData) Finalize ¶
func (_ *HeaderworksData) Finalize()
func (*HeaderworksData) NullField ¶
func (r *HeaderworksData) NullField(i int)
func (*HeaderworksData) Schema ¶
func (r *HeaderworksData) Schema() string
func (*HeaderworksData) SchemaName ¶
func (r *HeaderworksData) SchemaName() string
func (*HeaderworksData) SetBoolean ¶
func (_ *HeaderworksData) SetBoolean(v bool)
func (*HeaderworksData) SetBytes ¶
func (_ *HeaderworksData) SetBytes(v []byte)
func (*HeaderworksData) SetDefault ¶
func (r *HeaderworksData) SetDefault(i int)
func (*HeaderworksData) SetDouble ¶
func (_ *HeaderworksData) SetDouble(v float64)
func (*HeaderworksData) SetFloat ¶
func (_ *HeaderworksData) SetFloat(v float32)
func (*HeaderworksData) SetInt ¶
func (_ *HeaderworksData) SetInt(v int32)
func (*HeaderworksData) SetLong ¶
func (_ *HeaderworksData) SetLong(v int64)
func (*HeaderworksData) SetString ¶
func (_ *HeaderworksData) SetString(v string)
func (*HeaderworksData) SetUnionElem ¶
func (_ *HeaderworksData) SetUnionElem(v int64)
type HeaderworksDataReader ¶
type HeaderworksDataReader struct {
// contains filtered or unexported fields
}
container reader
func NewHeaderworksDataReader ¶
func NewHeaderworksDataReader(r io.Reader) (*HeaderworksDataReader, error)
func (HeaderworksDataReader) Read ¶
func (r HeaderworksDataReader) Read() (*HeaderworksData, error)
type HeaderworksTrace ¶
type HeaderworksTrace struct { // Trace Identifier TraceId *UnionNullDatatypeUUID `json:"traceId"` }
Trace
func DeserializeHeaderworksTrace ¶
func DeserializeHeaderworksTrace(r io.Reader) (*HeaderworksTrace, error)
func DeserializeHeaderworksTraceFromSchema ¶
func DeserializeHeaderworksTraceFromSchema(r io.Reader, schema string) (*HeaderworksTrace, error)
func NewHeaderworksTrace ¶
func NewHeaderworksTrace() *HeaderworksTrace
func (*HeaderworksTrace) AppendArray ¶
func (_ *HeaderworksTrace) AppendArray() types.Field
func (*HeaderworksTrace) AvroCRC64Fingerprint ¶
func (_ *HeaderworksTrace) AvroCRC64Fingerprint() []byte
func (*HeaderworksTrace) Finalize ¶
func (_ *HeaderworksTrace) Finalize()
func (*HeaderworksTrace) NullField ¶
func (r *HeaderworksTrace) NullField(i int)
func (*HeaderworksTrace) Schema ¶
func (r *HeaderworksTrace) Schema() string
func (*HeaderworksTrace) SchemaName ¶
func (r *HeaderworksTrace) SchemaName() string
func (*HeaderworksTrace) SetBoolean ¶
func (_ *HeaderworksTrace) SetBoolean(v bool)
func (*HeaderworksTrace) SetBytes ¶
func (_ *HeaderworksTrace) SetBytes(v []byte)
func (*HeaderworksTrace) SetDefault ¶
func (r *HeaderworksTrace) SetDefault(i int)
func (*HeaderworksTrace) SetDouble ¶
func (_ *HeaderworksTrace) SetDouble(v float64)
func (*HeaderworksTrace) SetFloat ¶
func (_ *HeaderworksTrace) SetFloat(v float32)
func (*HeaderworksTrace) SetInt ¶
func (_ *HeaderworksTrace) SetInt(v int32)
func (*HeaderworksTrace) SetLong ¶
func (_ *HeaderworksTrace) SetLong(v int64)
func (*HeaderworksTrace) SetString ¶
func (_ *HeaderworksTrace) SetString(v string)
func (*HeaderworksTrace) SetUnionElem ¶
func (_ *HeaderworksTrace) SetUnionElem(v int64)
type HeaderworksTraceReader ¶
type HeaderworksTraceReader struct {
// contains filtered or unexported fields
}
container reader
func NewHeaderworksTraceReader ¶
func NewHeaderworksTraceReader(r io.Reader) (*HeaderworksTraceReader, error)
func (HeaderworksTraceReader) Read ¶
func (r HeaderworksTraceReader) Read() (*HeaderworksTrace, error)
type TestSample ¶
type TestSample struct { // Core data information required for any event Header *UnionNullHeaderworksData `json:"header"` // Core data information required for any event Body *UnionNullBodyworksData `json:"body"` }
GoGen test
func DeserializeTestSample ¶
func DeserializeTestSample(r io.Reader) (*TestSample, error)
func DeserializeTestSampleFromSchema ¶
func DeserializeTestSampleFromSchema(r io.Reader, schema string) (*TestSample, error)
func NewTestSample ¶
func NewTestSample() *TestSample
func (*TestSample) AppendArray ¶
func (_ *TestSample) AppendArray() types.Field
func (*TestSample) AvroCRC64Fingerprint ¶
func (_ *TestSample) AvroCRC64Fingerprint() []byte
func (*TestSample) Finalize ¶
func (_ *TestSample) Finalize()
func (*TestSample) NullField ¶
func (r *TestSample) NullField(i int)
func (*TestSample) Schema ¶
func (r *TestSample) Schema() string
func (*TestSample) SchemaName ¶
func (r *TestSample) SchemaName() string
func (*TestSample) SetBoolean ¶
func (_ *TestSample) SetBoolean(v bool)
func (*TestSample) SetBytes ¶
func (_ *TestSample) SetBytes(v []byte)
func (*TestSample) SetDefault ¶
func (r *TestSample) SetDefault(i int)
func (*TestSample) SetDouble ¶
func (_ *TestSample) SetDouble(v float64)
func (*TestSample) SetFloat ¶
func (_ *TestSample) SetFloat(v float32)
func (*TestSample) SetInt ¶
func (_ *TestSample) SetInt(v int32)
func (*TestSample) SetLong ¶
func (_ *TestSample) SetLong(v int64)
func (*TestSample) SetString ¶
func (_ *TestSample) SetString(v string)
func (*TestSample) SetUnionElem ¶
func (_ *TestSample) SetUnionElem(v int64)
type TestSampleReader ¶
type TestSampleReader struct {
// contains filtered or unexported fields
}
container reader
func NewTestSampleReader ¶
func NewTestSampleReader(r io.Reader) (*TestSampleReader, error)
func (TestSampleReader) Read ¶
func (r TestSampleReader) Read() (*TestSample, error)
type UnionNullBodyworksData ¶
type UnionNullBodyworksData struct { Null *types.NullVal BodyworksData *BodyworksData UnionType UnionNullBodyworksDataTypeEnum }
func NewUnionNullBodyworksData ¶
func NewUnionNullBodyworksData() *UnionNullBodyworksData
func (*UnionNullBodyworksData) AppendArray ¶
func (_ *UnionNullBodyworksData) AppendArray() types.Field
func (*UnionNullBodyworksData) AppendMap ¶
func (_ *UnionNullBodyworksData) AppendMap(key string) types.Field
func (*UnionNullBodyworksData) Finalize ¶
func (_ *UnionNullBodyworksData) Finalize()
func (*UnionNullBodyworksData) MarshalJSON ¶
func (r *UnionNullBodyworksData) MarshalJSON() ([]byte, error)
func (*UnionNullBodyworksData) NullField ¶
func (_ *UnionNullBodyworksData) NullField(i int)
func (*UnionNullBodyworksData) SetBoolean ¶
func (_ *UnionNullBodyworksData) SetBoolean(v bool)
func (*UnionNullBodyworksData) SetBytes ¶
func (_ *UnionNullBodyworksData) SetBytes(v []byte)
func (*UnionNullBodyworksData) SetDefault ¶
func (_ *UnionNullBodyworksData) SetDefault(i int)
func (*UnionNullBodyworksData) SetDouble ¶
func (_ *UnionNullBodyworksData) SetDouble(v float64)
func (*UnionNullBodyworksData) SetFloat ¶
func (_ *UnionNullBodyworksData) SetFloat(v float32)
func (*UnionNullBodyworksData) SetInt ¶
func (_ *UnionNullBodyworksData) SetInt(v int32)
func (*UnionNullBodyworksData) SetLong ¶
func (r *UnionNullBodyworksData) SetLong(v int64)
func (*UnionNullBodyworksData) SetString ¶
func (_ *UnionNullBodyworksData) SetString(v string)
func (*UnionNullBodyworksData) UnmarshalJSON ¶
func (r *UnionNullBodyworksData) UnmarshalJSON(data []byte) error
type UnionNullBodyworksDataTypeEnum ¶
type UnionNullBodyworksDataTypeEnum int
const (
UnionNullBodyworksDataTypeEnumBodyworksData UnionNullBodyworksDataTypeEnum = 1
)
type UnionNullBodyworksTrace ¶
type UnionNullBodyworksTrace struct { Null *types.NullVal BodyworksTrace *BodyworksTrace UnionType UnionNullBodyworksTraceTypeEnum }
func NewUnionNullBodyworksTrace ¶
func NewUnionNullBodyworksTrace() *UnionNullBodyworksTrace
func (*UnionNullBodyworksTrace) AppendArray ¶
func (_ *UnionNullBodyworksTrace) AppendArray() types.Field
func (*UnionNullBodyworksTrace) AppendMap ¶
func (_ *UnionNullBodyworksTrace) AppendMap(key string) types.Field
func (*UnionNullBodyworksTrace) Finalize ¶
func (_ *UnionNullBodyworksTrace) Finalize()
func (*UnionNullBodyworksTrace) MarshalJSON ¶
func (r *UnionNullBodyworksTrace) MarshalJSON() ([]byte, error)
func (*UnionNullBodyworksTrace) NullField ¶
func (_ *UnionNullBodyworksTrace) NullField(i int)
func (*UnionNullBodyworksTrace) SetBoolean ¶
func (_ *UnionNullBodyworksTrace) SetBoolean(v bool)
func (*UnionNullBodyworksTrace) SetBytes ¶
func (_ *UnionNullBodyworksTrace) SetBytes(v []byte)
func (*UnionNullBodyworksTrace) SetDefault ¶
func (_ *UnionNullBodyworksTrace) SetDefault(i int)
func (*UnionNullBodyworksTrace) SetDouble ¶
func (_ *UnionNullBodyworksTrace) SetDouble(v float64)
func (*UnionNullBodyworksTrace) SetFloat ¶
func (_ *UnionNullBodyworksTrace) SetFloat(v float32)
func (*UnionNullBodyworksTrace) SetInt ¶
func (_ *UnionNullBodyworksTrace) SetInt(v int32)
func (*UnionNullBodyworksTrace) SetLong ¶
func (r *UnionNullBodyworksTrace) SetLong(v int64)
func (*UnionNullBodyworksTrace) SetString ¶
func (_ *UnionNullBodyworksTrace) SetString(v string)
func (*UnionNullBodyworksTrace) UnmarshalJSON ¶
func (r *UnionNullBodyworksTrace) UnmarshalJSON(data []byte) error
type UnionNullBodyworksTraceTypeEnum ¶
type UnionNullBodyworksTraceTypeEnum int
const (
UnionNullBodyworksTraceTypeEnumBodyworksTrace UnionNullBodyworksTraceTypeEnum = 1
)
type UnionNullDatatypeUUID ¶
type UnionNullDatatypeUUID struct { Null *types.NullVal DatatypeUUID *DatatypeUUID UnionType UnionNullDatatypeUUIDTypeEnum }
func NewUnionNullDatatypeUUID ¶
func NewUnionNullDatatypeUUID() *UnionNullDatatypeUUID
func (*UnionNullDatatypeUUID) AppendArray ¶
func (_ *UnionNullDatatypeUUID) AppendArray() types.Field
func (*UnionNullDatatypeUUID) AppendMap ¶
func (_ *UnionNullDatatypeUUID) AppendMap(key string) types.Field
func (*UnionNullDatatypeUUID) Finalize ¶
func (_ *UnionNullDatatypeUUID) Finalize()
func (*UnionNullDatatypeUUID) MarshalJSON ¶
func (r *UnionNullDatatypeUUID) MarshalJSON() ([]byte, error)
func (*UnionNullDatatypeUUID) NullField ¶
func (_ *UnionNullDatatypeUUID) NullField(i int)
func (*UnionNullDatatypeUUID) SetBoolean ¶
func (_ *UnionNullDatatypeUUID) SetBoolean(v bool)
func (*UnionNullDatatypeUUID) SetBytes ¶
func (_ *UnionNullDatatypeUUID) SetBytes(v []byte)
func (*UnionNullDatatypeUUID) SetDefault ¶
func (_ *UnionNullDatatypeUUID) SetDefault(i int)
func (*UnionNullDatatypeUUID) SetDouble ¶
func (_ *UnionNullDatatypeUUID) SetDouble(v float64)
func (*UnionNullDatatypeUUID) SetFloat ¶
func (_ *UnionNullDatatypeUUID) SetFloat(v float32)
func (*UnionNullDatatypeUUID) SetInt ¶
func (_ *UnionNullDatatypeUUID) SetInt(v int32)
func (*UnionNullDatatypeUUID) SetLong ¶
func (r *UnionNullDatatypeUUID) SetLong(v int64)
func (*UnionNullDatatypeUUID) SetString ¶
func (_ *UnionNullDatatypeUUID) SetString(v string)
func (*UnionNullDatatypeUUID) UnmarshalJSON ¶
func (r *UnionNullDatatypeUUID) UnmarshalJSON(data []byte) error
type UnionNullDatatypeUUIDTypeEnum ¶
type UnionNullDatatypeUUIDTypeEnum int
const (
UnionNullDatatypeUUIDTypeEnumDatatypeUUID UnionNullDatatypeUUIDTypeEnum = 1
)
type UnionNullHeaderworksData ¶
type UnionNullHeaderworksData struct { Null *types.NullVal HeaderworksData *HeaderworksData UnionType UnionNullHeaderworksDataTypeEnum }
func NewUnionNullHeaderworksData ¶
func NewUnionNullHeaderworksData() *UnionNullHeaderworksData
func (*UnionNullHeaderworksData) AppendArray ¶
func (_ *UnionNullHeaderworksData) AppendArray() types.Field
func (*UnionNullHeaderworksData) AppendMap ¶
func (_ *UnionNullHeaderworksData) AppendMap(key string) types.Field
func (*UnionNullHeaderworksData) Finalize ¶
func (_ *UnionNullHeaderworksData) Finalize()
func (*UnionNullHeaderworksData) MarshalJSON ¶
func (r *UnionNullHeaderworksData) MarshalJSON() ([]byte, error)
func (*UnionNullHeaderworksData) NullField ¶
func (_ *UnionNullHeaderworksData) NullField(i int)
func (*UnionNullHeaderworksData) SetBoolean ¶
func (_ *UnionNullHeaderworksData) SetBoolean(v bool)
func (*UnionNullHeaderworksData) SetBytes ¶
func (_ *UnionNullHeaderworksData) SetBytes(v []byte)
func (*UnionNullHeaderworksData) SetDefault ¶
func (_ *UnionNullHeaderworksData) SetDefault(i int)
func (*UnionNullHeaderworksData) SetDouble ¶
func (_ *UnionNullHeaderworksData) SetDouble(v float64)
func (*UnionNullHeaderworksData) SetFloat ¶
func (_ *UnionNullHeaderworksData) SetFloat(v float32)
func (*UnionNullHeaderworksData) SetInt ¶
func (_ *UnionNullHeaderworksData) SetInt(v int32)
func (*UnionNullHeaderworksData) SetLong ¶
func (r *UnionNullHeaderworksData) SetLong(v int64)
func (*UnionNullHeaderworksData) SetString ¶
func (_ *UnionNullHeaderworksData) SetString(v string)
func (*UnionNullHeaderworksData) UnmarshalJSON ¶
func (r *UnionNullHeaderworksData) UnmarshalJSON(data []byte) error
type UnionNullHeaderworksDataTypeEnum ¶
type UnionNullHeaderworksDataTypeEnum int
const (
UnionNullHeaderworksDataTypeEnumHeaderworksData UnionNullHeaderworksDataTypeEnum = 1
)
type UnionNullHeaderworksTrace ¶
type UnionNullHeaderworksTrace struct { Null *types.NullVal HeaderworksTrace *HeaderworksTrace UnionType UnionNullHeaderworksTraceTypeEnum }
func NewUnionNullHeaderworksTrace ¶
func NewUnionNullHeaderworksTrace() *UnionNullHeaderworksTrace
func (*UnionNullHeaderworksTrace) AppendArray ¶
func (_ *UnionNullHeaderworksTrace) AppendArray() types.Field
func (*UnionNullHeaderworksTrace) AppendMap ¶
func (_ *UnionNullHeaderworksTrace) AppendMap(key string) types.Field
func (*UnionNullHeaderworksTrace) Finalize ¶
func (_ *UnionNullHeaderworksTrace) Finalize()
func (*UnionNullHeaderworksTrace) MarshalJSON ¶
func (r *UnionNullHeaderworksTrace) MarshalJSON() ([]byte, error)
func (*UnionNullHeaderworksTrace) NullField ¶
func (_ *UnionNullHeaderworksTrace) NullField(i int)
func (*UnionNullHeaderworksTrace) SetBoolean ¶
func (_ *UnionNullHeaderworksTrace) SetBoolean(v bool)
func (*UnionNullHeaderworksTrace) SetBytes ¶
func (_ *UnionNullHeaderworksTrace) SetBytes(v []byte)
func (*UnionNullHeaderworksTrace) SetDefault ¶
func (_ *UnionNullHeaderworksTrace) SetDefault(i int)
func (*UnionNullHeaderworksTrace) SetDouble ¶
func (_ *UnionNullHeaderworksTrace) SetDouble(v float64)
func (*UnionNullHeaderworksTrace) SetFloat ¶
func (_ *UnionNullHeaderworksTrace) SetFloat(v float32)
func (*UnionNullHeaderworksTrace) SetInt ¶
func (_ *UnionNullHeaderworksTrace) SetInt(v int32)
func (*UnionNullHeaderworksTrace) SetLong ¶
func (r *UnionNullHeaderworksTrace) SetLong(v int64)
func (*UnionNullHeaderworksTrace) SetString ¶
func (_ *UnionNullHeaderworksTrace) SetString(v string)
func (*UnionNullHeaderworksTrace) UnmarshalJSON ¶
func (r *UnionNullHeaderworksTrace) UnmarshalJSON(data []byte) error
type UnionNullHeaderworksTraceTypeEnum ¶
type UnionNullHeaderworksTraceTypeEnum int
const (
UnionNullHeaderworksTraceTypeEnumHeaderworksTrace UnionNullHeaderworksTraceTypeEnum = 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) Finalize ¶
func (_ *UnionNullString) Finalize()
func (*UnionNullString) MarshalJSON ¶
func (r *UnionNullString) MarshalJSON() ([]byte, error)
func (*UnionNullString) NullField ¶
func (_ *UnionNullString) NullField(i int)
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)
func (*UnionNullString) UnmarshalJSON ¶
func (r *UnionNullString) UnmarshalJSON(data []byte) error
type UnionNullStringTypeEnum ¶
type UnionNullStringTypeEnum int
const (
UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)
Source Files ¶
- bodyworks_data.go
- bodyworks_data_container.go
- bodyworks_trace.go
- bodyworks_trace_container.go
- datatype_uuid.go
- datatype_uuid_container.go
- generate.go
- headerworks_data.go
- headerworks_data_container.go
- headerworks_trace.go
- headerworks_trace_container.go
- test_sample.go
- test_sample_container.go
- union_null_bodyworks_data.go
- union_null_bodyworks_trace.go
- union_null_datatype_uuid.go
- union_null_headerworks_data.go
- union_null_headerworks_trace.go
- union_null_string.go