oteltef

package
v0.0.0-...-eecd29b Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2025 License: Apache-2.0 Imports: 12 Imported by: 4

Documentation

Overview

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Code generated by stefgen. DO NOT EDIT.

Index

Constants

View Source 
const (
	AnyValueTypeNone = AnyValueType(iota)
	AnyValueTypeString
	AnyValueTypeBool
	AnyValueTypeInt64
	AnyValueTypeFloat64
	AnyValueTypeArray
	AnyValueTypeKVList
	AnyValueTypeBytes
	AnyValueTypeCount
)
View Source 
const (
	ExemplarValueTypeNone = ExemplarValueType(iota)
	ExemplarValueTypeInt64
	ExemplarValueTypeFloat64
	ExemplarValueTypeCount
)
View Source 
const (
	PointValueTypeNone = PointValueType(iota)
	PointValueTypeInt64
	PointValueTypeFloat64
	PointValueTypeHistogram
	PointValueTypeCount
)

Variables

This section is empty.

Functions

func AnyValueEqual 

func AnyValueEqual(left, right *AnyValue) bool

func CmpAnyValue 

func CmpAnyValue(left, right *AnyValue) int

CmpAnyValue performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpAnyValueArray 

func CmpAnyValueArray(left, right *AnyValueArray) int

CmpAnyValueArray performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpAttributes 

func CmpAttributes(left, right *Attributes) int

func CmpEnvelope 

func CmpEnvelope(left, right *Envelope) int

CmpEnvelope performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpEnvelopeAttributes 

func CmpEnvelopeAttributes(left, right *EnvelopeAttributes) int

func CmpEvent 

func CmpEvent(left, right *Event) int

CmpEvent performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpEventArray 

func CmpEventArray(left, right *EventArray) int

CmpEventArray performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpExemplar 

func CmpExemplar(left, right *Exemplar) int

CmpExemplar performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpExemplarArray 

func CmpExemplarArray(left, right *ExemplarArray) int

CmpExemplarArray performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpExemplarValue 

func CmpExemplarValue(left, right *ExemplarValue) int

CmpExemplarValue performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpFloat64Array 

func CmpFloat64Array(left, right *Float64Array) int

CmpFloat64Array performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpHistogramValue 

func CmpHistogramValue(left, right *HistogramValue) int

CmpHistogramValue performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpInt64Array 

func CmpInt64Array(left, right *Int64Array) int

CmpInt64Array performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpKeyValueList 

func CmpKeyValueList(left, right *KeyValueList) int
func CmpLink(left, right *Link) int

CmpLink performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpLinkArray 

func CmpLinkArray(left, right *LinkArray) int

CmpLinkArray performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpMetric 

func CmpMetric(left, right *Metric) int

CmpMetric performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpMetrics 

func CmpMetrics(left, right *Metrics) int

CmpMetrics performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpPoint 

func CmpPoint(left, right *Point) int

CmpPoint performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpPointValue 

func CmpPointValue(left, right *PointValue) int

CmpPointValue performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpResource 

func CmpResource(left, right *Resource) int

CmpResource performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpScope 

func CmpScope(left, right *Scope) int

CmpScope performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpSpan 

func CmpSpan(left, right *Span) int

CmpSpan performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpSpanStatus 

func CmpSpanStatus(left, right *SpanStatus) int

CmpSpanStatus performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func CmpSpans 

func CmpSpans(left, right *Spans) int

CmpSpans performs deep comparison and returns an integer that will be 0 if left == right, negative if left < right, positive if left > right.

func EnvelopeEqual 

func EnvelopeEqual(left, right *Envelope) bool

func EventEqual 

func EventEqual(left, right *Event) bool

func ExemplarEqual 

func ExemplarEqual(left, right *Exemplar) bool

func ExemplarValueEqual 

func ExemplarValueEqual(left, right *ExemplarValue) bool

func HistogramValueEqual 

func HistogramValueEqual(left, right *HistogramValue) bool

func LinkEqual 

func LinkEqual(left, right *Link) bool

func MetricEqual 

func MetricEqual(left, right *Metric) bool

func MetricsEqual 

func MetricsEqual(left, right *Metrics) bool

func MetricsWireSchema 

func MetricsWireSchema() (*schema.Schema, error)

func PointEqual 

func PointEqual(left, right *Point) bool

func PointValueEqual 

func PointValueEqual(left, right *PointValue) bool

func ResourceEqual 

func ResourceEqual(left, right *Resource) bool

func ScopeEqual 

func ScopeEqual(left, right *Scope) bool

func SpanEqual 

func SpanEqual(left, right *Span) bool

func SpanStatusEqual 

func SpanStatusEqual(left, right *SpanStatus) bool

func SpansEqual 

func SpansEqual(left, right *Spans) bool

func SpansWireSchema 

func SpansWireSchema() (*schema.Schema, error)

Types

type AnyValue 

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

AnyValue is a oneof struct.

func (*AnyValue) Array 

func (s *AnyValue) Array() *AnyValueArray

Array returns the value if the contained type is currently AnyValueTypeArray. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) Bool 

func (s *AnyValue) Bool() bool

Bool returns the value if the contained type is currently AnyValueTypeBool. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) Bytes 

func (s *AnyValue) Bytes() pkg.Bytes

Bytes returns the value if the contained type is currently AnyValueTypeBytes. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) CopyFrom 

func (s *AnyValue) CopyFrom(src *AnyValue)

CopyFrom() performs a deep copy from src.

func (*AnyValue) Float64 

func (s *AnyValue) Float64() float64

Float64 returns the value if the contained type is currently AnyValueTypeFloat64. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) Init 

func (s *AnyValue) Init()

Init must be called once, before the AnyValue is used.

func (*AnyValue) Int64 

func (s *AnyValue) Int64() int64

Int64 returns the value if the contained type is currently AnyValueTypeInt64. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) IsEqual 

func (e *AnyValue) IsEqual(val *AnyValue) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*AnyValue) KVList 

func (s *AnyValue) KVList() *KeyValueList

KVList returns the value if the contained type is currently AnyValueTypeKVList. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) SetBool 

func (s *AnyValue) SetBool(v bool)

SetBool sets the value to the specified value and sets the type to AnyValueTypeBool.

func (*AnyValue) SetBytes 

func (s *AnyValue) SetBytes(v pkg.Bytes)

SetBytes sets the value to the specified value and sets the type to AnyValueTypeBytes.

func (*AnyValue) SetFloat64 

func (s *AnyValue) SetFloat64(v float64)

SetFloat64 sets the value to the specified value and sets the type to AnyValueTypeFloat64.

func (*AnyValue) SetInt64 

func (s *AnyValue) SetInt64(v int64)

SetInt64 sets the value to the specified value and sets the type to AnyValueTypeInt64.

func (*AnyValue) SetString 

func (s *AnyValue) SetString(v string)

SetString sets the value to the specified value and sets the type to AnyValueTypeString.

func (*AnyValue) SetType 

func (s *AnyValue) SetType(typ AnyValueType)

SetType sets the type of the value currently contained in AnyValue.

func (*AnyValue) String 

func (s *AnyValue) String() string

String returns the value if the contained type is currently AnyValueTypeString. The caller must check the type via Type() before attempting to call this function.

func (*AnyValue) Type 

func (s *AnyValue) Type() AnyValueType

Type returns the type of the value currently contained in AnyValue.

type AnyValueArray 

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

AnyValueArray is a variable size array.

func (*AnyValueArray) Append 

func (e *AnyValueArray) Append(val *AnyValue)

Append a new element at the end of the array.

func (*AnyValueArray) At 

func (m *AnyValueArray) At(i int) *AnyValue

At returns element at index i.

func (*AnyValueArray) Clone 

func (e *AnyValueArray) Clone() AnyValueArray

Clone() creates a deep copy of AnyValueArray

func (*AnyValueArray) EnsureLen 

func (e *AnyValueArray) EnsureLen(newLen int)

EnsureLen ensures the length of the array is equal to newLen. It will grow or shrink the array if needed.

func (*AnyValueArray) IsEqual 

func (e *AnyValueArray) IsEqual(val *AnyValueArray) bool

IsEqual performs deep comparison and returns true if array is equal to val.

func (*AnyValueArray) Len 

func (e *AnyValueArray) Len() int

Len returns the number of elements in the array.

type AnyValueArrayDecoder 

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

func (*AnyValueArrayDecoder) Continue 

func (d *AnyValueArrayDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*AnyValueArrayDecoder) Decode 

func (d *AnyValueArrayDecoder) Decode(dst *AnyValueArray) error

func (*AnyValueArrayDecoder) Init 

func (d *AnyValueArrayDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*AnyValueArrayDecoder) Reset 

func (d *AnyValueArrayDecoder) Reset()

type AnyValueArrayEncoder 

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

func (*AnyValueArrayEncoder) CollectColumns 

func (e *AnyValueArrayEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*AnyValueArrayEncoder) Encode 

func (e *AnyValueArrayEncoder) Encode(arr *AnyValueArray)

func (*AnyValueArrayEncoder) Init 

func (e *AnyValueArrayEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*AnyValueArrayEncoder) Reset 

func (e *AnyValueArrayEncoder) Reset()

type AnyValueDecoder 

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

AnyValueDecoder implements decoding of AnyValue

func (*AnyValueDecoder) Continue 

func (d *AnyValueDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*AnyValueDecoder) Decode 

func (d *AnyValueDecoder) Decode(dstPtr *AnyValue) error

func (*AnyValueDecoder) Init 

func (d *AnyValueDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*AnyValueDecoder) Reset 

func (d *AnyValueDecoder) Reset()

type AnyValueEncoder 

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

AnyValueEncoder implements encoding of AnyValue

func (*AnyValueEncoder) CollectColumns 

func (e *AnyValueEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*AnyValueEncoder) Encode 

func (e *AnyValueEncoder) Encode(val *AnyValue)

Encode encodes val into buf

func (*AnyValueEncoder) Init 

func (e *AnyValueEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*AnyValueEncoder) Reset 

func (e *AnyValueEncoder) Reset()

type AnyValueType 

type AnyValueType byte

type Attributes 

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

Attributes is a multimap, (aka an associative array or a list) of key value pairs from string to AnyValue.

func (*Attributes) At 

func (m *Attributes) At(i int) *AttributesElem

At returns element at index i.

func (*Attributes) Clone 

func (m *Attributes) Clone() Attributes

Clone() creates a deep copy of Attributes

func (*Attributes) CopyFrom 

func (m *Attributes) CopyFrom(src *Attributes)

func (*Attributes) EnsureLen 

func (m *Attributes) EnsureLen(newLen int)

EnsureLen ensures the length of the multimap is equal to newLen. It will grow or shrink the multimap if needed.

func (*Attributes) IsEqual 

func (e *Attributes) IsEqual(val *Attributes) bool

func (*Attributes) Len 

func (m *Attributes) Len() int

Len returns the number of elements in the multimap.

func (*Attributes) SetKey 

func (m *Attributes) SetKey(i int, k string)

SetKey sets the key of the element at index i.

func (*Attributes) Sort 

func (m *Attributes) Sort()

type AttributesDecoder 

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

func (*AttributesDecoder) Continue 

func (d *AttributesDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*AttributesDecoder) Decode 

func (d *AttributesDecoder) Decode(dst *Attributes) error

func (*AttributesDecoder) Init 

func (d *AttributesDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*AttributesDecoder) Reset 

func (d *AttributesDecoder) Reset()

type AttributesElem 

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

func (*AttributesElem) Key 

func (e *AttributesElem) Key() string

func (*AttributesElem) Value 

func (e *AttributesElem) Value() *AnyValue

type AttributesEncoder 

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

func (*AttributesEncoder) CollectColumns 

func (e *AttributesEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*AttributesEncoder) Encode 

func (e *AttributesEncoder) Encode(list *Attributes) (changed bool)

func (*AttributesEncoder) Init 

func (e *AttributesEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*AttributesEncoder) IsEqual 

func (e *AttributesEncoder) IsEqual(list *Attributes) bool

IsEqual performs deep comparison and returns true if encoder's previously encoded value is equal to list.

func (*AttributesEncoder) RencodeLast 

func (e *AttributesEncoder) RencodeLast()

func (*AttributesEncoder) Reset 

func (e *AttributesEncoder) Reset()

type Envelope 

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

func NewEnvelope 

func NewEnvelope() *Envelope

func (*Envelope) Attributes 

func (s *Envelope) Attributes() *EnvelopeAttributes

func (*Envelope) CopyFrom 

func (s *Envelope) CopyFrom(src *Envelope)

CopyFrom() performs a deep copy from src.

func (*Envelope) Init 

func (s *Envelope) Init()

Init must be called once, before the Envelope is used.

func (*Envelope) IsAttributesModified 

func (s *Envelope) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Envelope was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Envelope) IsEqual 

func (e *Envelope) IsEqual(val *Envelope) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

type EnvelopeAttributes 

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

EnvelopeAttributes is a multimap, (aka an associative array or a list) of key value pairs from string to Bytes.

func (*EnvelopeAttributes) Append 

func (m *EnvelopeAttributes) Append(k string, v pkg.Bytes)

func (*EnvelopeAttributes) At 

func (m *EnvelopeAttributes) At(i int) *EnvelopeAttributesElem

At returns element at index i.

func (*EnvelopeAttributes) Clone 

func (m *EnvelopeAttributes) Clone() EnvelopeAttributes

Clone() creates a deep copy of EnvelopeAttributes

func (*EnvelopeAttributes) CopyFrom 

func (m *EnvelopeAttributes) CopyFrom(src *EnvelopeAttributes)

func (*EnvelopeAttributes) EnsureLen 

func (m *EnvelopeAttributes) EnsureLen(newLen int)

EnsureLen ensures the length of the multimap is equal to newLen. It will grow or shrink the multimap if needed.

func (*EnvelopeAttributes) IsEqual 

func (e *EnvelopeAttributes) IsEqual(val *EnvelopeAttributes) bool

func (*EnvelopeAttributes) Len 

func (m *EnvelopeAttributes) Len() int

Len returns the number of elements in the multimap.

func (*EnvelopeAttributes) SetKey 

func (m *EnvelopeAttributes) SetKey(i int, k string)

SetKey sets the key of the element at index i.

func (*EnvelopeAttributes) SetValue 

func (m *EnvelopeAttributes) SetValue(i int, v pkg.Bytes)

SetValue sets the value of the element at index i.

func (*EnvelopeAttributes) Sort 

func (m *EnvelopeAttributes) Sort()

type EnvelopeAttributesDecoder 

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

func (*EnvelopeAttributesDecoder) Continue 

func (d *EnvelopeAttributesDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*EnvelopeAttributesDecoder) Decode 

func (d *EnvelopeAttributesDecoder) Decode(dst *EnvelopeAttributes) error

func (*EnvelopeAttributesDecoder) Init 

func (d *EnvelopeAttributesDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*EnvelopeAttributesDecoder) Reset 

func (d *EnvelopeAttributesDecoder) Reset()

type EnvelopeAttributesElem 

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

func (*EnvelopeAttributesElem) Key 

func (e *EnvelopeAttributesElem) Key() string

func (*EnvelopeAttributesElem) Value 

func (e *EnvelopeAttributesElem) Value() pkg.Bytes

type EnvelopeAttributesEncoder 

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

func (*EnvelopeAttributesEncoder) CollectColumns 

func (e *EnvelopeAttributesEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*EnvelopeAttributesEncoder) Encode 

func (e *EnvelopeAttributesEncoder) Encode(list *EnvelopeAttributes) (changed bool)

func (*EnvelopeAttributesEncoder) Init 

func (e *EnvelopeAttributesEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*EnvelopeAttributesEncoder) IsEqual 

func (e *EnvelopeAttributesEncoder) IsEqual(list *EnvelopeAttributes) bool

IsEqual performs deep comparison and returns true if encoder's previously encoded value is equal to list.

func (*EnvelopeAttributesEncoder) RencodeLast 

func (e *EnvelopeAttributesEncoder) RencodeLast()

func (*EnvelopeAttributesEncoder) Reset 

func (e *EnvelopeAttributesEncoder) Reset()

type EnvelopeDecoder 

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

EnvelopeDecoder implements decoding of Envelope

func (*EnvelopeDecoder) Continue 

func (d *EnvelopeDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*EnvelopeDecoder) Decode 

func (d *EnvelopeDecoder) Decode(dstPtr *Envelope) error

func (*EnvelopeDecoder) Init 

func (d *EnvelopeDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*EnvelopeDecoder) Reset 

func (d *EnvelopeDecoder) Reset()

type EnvelopeEncoder 

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

EnvelopeEncoder implements encoding of Envelope

func (*EnvelopeEncoder) CollectColumns 

func (e *EnvelopeEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*EnvelopeEncoder) Encode 

func (e *EnvelopeEncoder) Encode(val *Envelope)

Encode encodes val into buf

func (*EnvelopeEncoder) Init 

func (e *EnvelopeEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*EnvelopeEncoder) Reset 

func (e *EnvelopeEncoder) Reset()

type Event 

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

func NewEvent 

func NewEvent() *Event

func (*Event) Attributes 

func (s *Event) Attributes() *Attributes

func (*Event) CopyFrom 

func (s *Event) CopyFrom(src *Event)

CopyFrom() performs a deep copy from src.

func (*Event) Init 

func (s *Event) Init()

Init must be called once, before the Event is used.

func (*Event) IsAttributesModified 

func (s *Event) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Event was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Event) IsEqual 

func (e *Event) IsEqual(val *Event) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Event) IsNameModified 

func (s *Event) IsNameModified() bool

IsNameModified returns true the value of Name field was modified since Event was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Event) IsTimeUnixNanoModified 

func (s *Event) IsTimeUnixNanoModified() bool

IsTimeUnixNanoModified returns true the value of TimeUnixNano field was modified since Event was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Event) Name 

func (s *Event) Name() string

func (*Event) SetName 

func (s *Event) SetName(v string)

SetName sets the value of Name field.

func (*Event) SetTimeUnixNano 

func (s *Event) SetTimeUnixNano(v uint64)

SetTimeUnixNano sets the value of TimeUnixNano field.

func (*Event) TimeUnixNano 

func (s *Event) TimeUnixNano() uint64

type EventArray 

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

EventArray is a variable size array.

func (*EventArray) Append 

func (e *EventArray) Append(val *Event)

Append a new element at the end of the array.

func (*EventArray) At 

func (m *EventArray) At(i int) *Event

At returns element at index i.

func (*EventArray) Clone 

func (e *EventArray) Clone() EventArray

Clone() creates a deep copy of EventArray

func (*EventArray) EnsureLen 

func (e *EventArray) EnsureLen(newLen int)

EnsureLen ensures the length of the array is equal to newLen. It will grow or shrink the array if needed.

func (*EventArray) IsEqual 

func (e *EventArray) IsEqual(val *EventArray) bool

IsEqual performs deep comparison and returns true if array is equal to val.

func (*EventArray) Len 

func (e *EventArray) Len() int

Len returns the number of elements in the array.

type EventArrayDecoder 

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

func (*EventArrayDecoder) Continue 

func (d *EventArrayDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*EventArrayDecoder) Decode 

func (d *EventArrayDecoder) Decode(dst *EventArray) error

func (*EventArrayDecoder) Init 

func (d *EventArrayDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*EventArrayDecoder) Reset 

func (d *EventArrayDecoder) Reset()

type EventArrayEncoder 

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

func (*EventArrayEncoder) CollectColumns 

func (e *EventArrayEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*EventArrayEncoder) Encode 

func (e *EventArrayEncoder) Encode(arr *EventArray)

func (*EventArrayEncoder) Init 

func (e *EventArrayEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*EventArrayEncoder) Reset 

func (e *EventArrayEncoder) Reset()

type EventDecoder 

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

EventDecoder implements decoding of Event

func (*EventDecoder) Continue 

func (d *EventDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*EventDecoder) Decode 

func (d *EventDecoder) Decode(dstPtr *Event) error

func (*EventDecoder) Init 

func (d *EventDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*EventDecoder) Reset 

func (d *EventDecoder) Reset()

type EventEncoder 

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

EventEncoder implements encoding of Event

func (*EventEncoder) CollectColumns 

func (e *EventEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*EventEncoder) Encode 

func (e *EventEncoder) Encode(val *Event)

Encode encodes val into buf

func (*EventEncoder) Init 

func (e *EventEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*EventEncoder) Reset 

func (e *EventEncoder) Reset()

type Exemplar 

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

func NewExemplar 

func NewExemplar() *Exemplar

func (*Exemplar) CopyFrom 

func (s *Exemplar) CopyFrom(src *Exemplar)

CopyFrom() performs a deep copy from src.

func (*Exemplar) FilteredAttributes 

func (s *Exemplar) FilteredAttributes() *Attributes

func (*Exemplar) Init 

func (s *Exemplar) Init()

Init must be called once, before the Exemplar is used.

func (*Exemplar) IsEqual 

func (e *Exemplar) IsEqual(val *Exemplar) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Exemplar) IsFilteredAttributesModified 

func (s *Exemplar) IsFilteredAttributesModified() bool

IsFilteredAttributesModified returns true the value of FilteredAttributes field was modified since Exemplar was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Exemplar) IsSpanIDModified 

func (s *Exemplar) IsSpanIDModified() bool

IsSpanIDModified returns true the value of SpanID field was modified since Exemplar was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Exemplar) IsTimestampModified 

func (s *Exemplar) IsTimestampModified() bool

IsTimestampModified returns true the value of Timestamp field was modified since Exemplar was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Exemplar) IsTraceIDModified 

func (s *Exemplar) IsTraceIDModified() bool

IsTraceIDModified returns true the value of TraceID field was modified since Exemplar was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Exemplar) IsValueModified 

func (s *Exemplar) IsValueModified() bool

IsValueModified returns true the value of Value field was modified since Exemplar was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Exemplar) SetSpanID 

func (s *Exemplar) SetSpanID(v pkg.Bytes)

SetSpanID sets the value of SpanID field.

func (*Exemplar) SetTimestamp 

func (s *Exemplar) SetTimestamp(v uint64)

SetTimestamp sets the value of Timestamp field.

func (*Exemplar) SetTraceID 

func (s *Exemplar) SetTraceID(v pkg.Bytes)

SetTraceID sets the value of TraceID field.

func (*Exemplar) SpanID 

func (s *Exemplar) SpanID() pkg.Bytes

func (*Exemplar) Timestamp 

func (s *Exemplar) Timestamp() uint64

func (*Exemplar) TraceID 

func (s *Exemplar) TraceID() pkg.Bytes

func (*Exemplar) Value 

func (s *Exemplar) Value() *ExemplarValue

type ExemplarArray 

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

ExemplarArray is a variable size array.

func (*ExemplarArray) Append 

func (e *ExemplarArray) Append(val *Exemplar)

Append a new element at the end of the array.

func (*ExemplarArray) At 

func (m *ExemplarArray) At(i int) *Exemplar

At returns element at index i.

func (*ExemplarArray) Clone 

func (e *ExemplarArray) Clone() ExemplarArray

Clone() creates a deep copy of ExemplarArray

func (*ExemplarArray) EnsureLen 

func (e *ExemplarArray) EnsureLen(newLen int)

EnsureLen ensures the length of the array is equal to newLen. It will grow or shrink the array if needed.

func (*ExemplarArray) IsEqual 

func (e *ExemplarArray) IsEqual(val *ExemplarArray) bool

IsEqual performs deep comparison and returns true if array is equal to val.

func (*ExemplarArray) Len 

func (e *ExemplarArray) Len() int

Len returns the number of elements in the array.

type ExemplarArrayDecoder 

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

func (*ExemplarArrayDecoder) Continue 

func (d *ExemplarArrayDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*ExemplarArrayDecoder) Decode 

func (d *ExemplarArrayDecoder) Decode(dst *ExemplarArray) error

func (*ExemplarArrayDecoder) Init 

func (d *ExemplarArrayDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*ExemplarArrayDecoder) Reset 

func (d *ExemplarArrayDecoder) Reset()

type ExemplarArrayEncoder 

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

func (*ExemplarArrayEncoder) CollectColumns 

func (e *ExemplarArrayEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*ExemplarArrayEncoder) Encode 

func (e *ExemplarArrayEncoder) Encode(arr *ExemplarArray)

func (*ExemplarArrayEncoder) Init 

func (e *ExemplarArrayEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*ExemplarArrayEncoder) Reset 

func (e *ExemplarArrayEncoder) Reset()

type ExemplarDecoder 

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

ExemplarDecoder implements decoding of Exemplar

func (*ExemplarDecoder) Continue 

func (d *ExemplarDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*ExemplarDecoder) Decode 

func (d *ExemplarDecoder) Decode(dstPtr *Exemplar) error

func (*ExemplarDecoder) Init 

func (d *ExemplarDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*ExemplarDecoder) Reset 

func (d *ExemplarDecoder) Reset()

type ExemplarEncoder 

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

ExemplarEncoder implements encoding of Exemplar

func (*ExemplarEncoder) CollectColumns 

func (e *ExemplarEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*ExemplarEncoder) Encode 

func (e *ExemplarEncoder) Encode(val *Exemplar)

Encode encodes val into buf

func (*ExemplarEncoder) Init 

func (e *ExemplarEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*ExemplarEncoder) Reset 

func (e *ExemplarEncoder) Reset()

type ExemplarValue 

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

ExemplarValue is a oneof struct.

func (*ExemplarValue) CopyFrom 

func (s *ExemplarValue) CopyFrom(src *ExemplarValue)

CopyFrom() performs a deep copy from src.

func (*ExemplarValue) Float64 

func (s *ExemplarValue) Float64() float64

Float64 returns the value if the contained type is currently ExemplarValueTypeFloat64. The caller must check the type via Type() before attempting to call this function.

func (*ExemplarValue) Init 

func (s *ExemplarValue) Init()

Init must be called once, before the ExemplarValue is used.

func (*ExemplarValue) Int64 

func (s *ExemplarValue) Int64() int64

Int64 returns the value if the contained type is currently ExemplarValueTypeInt64. The caller must check the type via Type() before attempting to call this function.

func (*ExemplarValue) IsEqual 

func (e *ExemplarValue) IsEqual(val *ExemplarValue) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*ExemplarValue) SetFloat64 

func (s *ExemplarValue) SetFloat64(v float64)

SetFloat64 sets the value to the specified value and sets the type to ExemplarValueTypeFloat64.

func (*ExemplarValue) SetInt64 

func (s *ExemplarValue) SetInt64(v int64)

SetInt64 sets the value to the specified value and sets the type to ExemplarValueTypeInt64.

func (*ExemplarValue) SetType 

func (s *ExemplarValue) SetType(typ ExemplarValueType)

SetType sets the type of the value currently contained in ExemplarValue.

func (*ExemplarValue) Type 

func (s *ExemplarValue) Type() ExemplarValueType

Type returns the type of the value currently contained in ExemplarValue.

type ExemplarValueDecoder 

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

ExemplarValueDecoder implements decoding of ExemplarValue

func (*ExemplarValueDecoder) Continue 

func (d *ExemplarValueDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*ExemplarValueDecoder) Decode 

func (d *ExemplarValueDecoder) Decode(dstPtr *ExemplarValue) error

func (*ExemplarValueDecoder) Init 

func (d *ExemplarValueDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*ExemplarValueDecoder) Reset 

func (d *ExemplarValueDecoder) Reset()

type ExemplarValueEncoder 

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

ExemplarValueEncoder implements encoding of ExemplarValue

func (*ExemplarValueEncoder) CollectColumns 

func (e *ExemplarValueEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*ExemplarValueEncoder) Encode 

func (e *ExemplarValueEncoder) Encode(val *ExemplarValue)

Encode encodes val into buf

func (*ExemplarValueEncoder) Init 

func (e *ExemplarValueEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*ExemplarValueEncoder) Reset 

func (e *ExemplarValueEncoder) Reset()

type ExemplarValueType 

type ExemplarValueType byte

type Float64Array 

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

Float64Array is a variable size array.

func (*Float64Array) Append 

func (e *Float64Array) Append(val float64)

Append a new element at the end of the array.

func (*Float64Array) At 

func (m *Float64Array) At(i int) float64

At returns element at index i.

func (*Float64Array) Clone 

func (e *Float64Array) Clone() Float64Array

Clone() creates a deep copy of Float64Array

func (*Float64Array) CopyFromSlice 

func (e *Float64Array) CopyFromSlice(src []float64)

CopyFromSlice copies from a slice into this array. The length of the array will be equal to the length of slice and elements of the array will be assigned from elements of the slice.

func (*Float64Array) EnsureLen 

func (e *Float64Array) EnsureLen(newLen int)

EnsureLen ensures the length of the array is equal to newLen. It will grow or shrink the array if needed.

func (*Float64Array) IsEqual 

func (e *Float64Array) IsEqual(val *Float64Array) bool

IsEqual performs deep comparison and returns true if array is equal to val.

func (*Float64Array) Len 

func (e *Float64Array) Len() int

Len returns the number of elements in the array.

type Float64ArrayDecoder 

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

func (*Float64ArrayDecoder) Continue 

func (d *Float64ArrayDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*Float64ArrayDecoder) Decode 

func (d *Float64ArrayDecoder) Decode(dst *Float64Array) error

func (*Float64ArrayDecoder) Init 

func (d *Float64ArrayDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*Float64ArrayDecoder) Reset 

func (d *Float64ArrayDecoder) Reset()

type Float64ArrayEncoder 

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

func (*Float64ArrayEncoder) CollectColumns 

func (e *Float64ArrayEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*Float64ArrayEncoder) Encode 

func (e *Float64ArrayEncoder) Encode(arr *Float64Array)

func (*Float64ArrayEncoder) Init 

func (e *Float64ArrayEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*Float64ArrayEncoder) Reset 

func (e *Float64ArrayEncoder) Reset()

type HistogramValue 

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

func NewHistogramValue 

func NewHistogramValue() *HistogramValue

func (*HistogramValue) BucketCounts 

func (s *HistogramValue) BucketCounts() *Int64Array

func (*HistogramValue) CopyFrom 

func (s *HistogramValue) CopyFrom(src *HistogramValue)

CopyFrom() performs a deep copy from src.

func (*HistogramValue) Count 

func (s *HistogramValue) Count() int64

func (*HistogramValue) HasMax 

func (s *HistogramValue) HasMax() bool

HasMax returns true if the presence flag Max field is set and false if it is unset.

func (*HistogramValue) HasMin 

func (s *HistogramValue) HasMin() bool

HasMin returns true if the presence flag Min field is set and false if it is unset.

func (*HistogramValue) HasSum 

func (s *HistogramValue) HasSum() bool

HasSum returns true if the presence flag Sum field is set and false if it is unset.

func (*HistogramValue) Init 

func (s *HistogramValue) Init()

Init must be called once, before the HistogramValue is used.

func (*HistogramValue) IsBucketCountsModified 

func (s *HistogramValue) IsBucketCountsModified() bool

IsBucketCountsModified returns true the value of BucketCounts field was modified since HistogramValue was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*HistogramValue) IsCountModified 

func (s *HistogramValue) IsCountModified() bool

IsCountModified returns true the value of Count field was modified since HistogramValue was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*HistogramValue) IsEqual 

func (e *HistogramValue) IsEqual(val *HistogramValue) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*HistogramValue) IsMaxModified 

func (s *HistogramValue) IsMaxModified() bool

IsMaxModified returns true the value of Max field was modified since HistogramValue was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*HistogramValue) IsMinModified 

func (s *HistogramValue) IsMinModified() bool

IsMinModified returns true the value of Min field was modified since HistogramValue was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*HistogramValue) IsSumModified 

func (s *HistogramValue) IsSumModified() bool

IsSumModified returns true the value of Sum field was modified since HistogramValue was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*HistogramValue) Max 

func (s *HistogramValue) Max() float64

func (*HistogramValue) Min 

func (s *HistogramValue) Min() float64

func (*HistogramValue) SetCount 

func (s *HistogramValue) SetCount(v int64)

SetCount sets the value of Count field.

func (*HistogramValue) SetMax 

func (s *HistogramValue) SetMax(v float64)

SetMax sets the value of Max field.

func (*HistogramValue) SetMin 

func (s *HistogramValue) SetMin(v float64)

SetMin sets the value of Min field.

func (*HistogramValue) SetSum 

func (s *HistogramValue) SetSum(v float64)

SetSum sets the value of Sum field.

func (*HistogramValue) Sum 

func (s *HistogramValue) Sum() float64

func (*HistogramValue) UnsetMax 

func (s *HistogramValue) UnsetMax()

UnsetMax unsets the precense flag of Max field. A subsequent HasMax() will return false.

func (*HistogramValue) UnsetMin 

func (s *HistogramValue) UnsetMin()

UnsetMin unsets the precense flag of Min field. A subsequent HasMin() will return false.

func (*HistogramValue) UnsetSum 

func (s *HistogramValue) UnsetSum()

UnsetSum unsets the precense flag of Sum field. A subsequent HasSum() will return false.

type HistogramValueDecoder 

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

HistogramValueDecoder implements decoding of HistogramValue

func (*HistogramValueDecoder) Continue 

func (d *HistogramValueDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*HistogramValueDecoder) Decode 

func (d *HistogramValueDecoder) Decode(dstPtr *HistogramValue) error

func (*HistogramValueDecoder) Init 

func (d *HistogramValueDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*HistogramValueDecoder) Reset 

func (d *HistogramValueDecoder) Reset()

type HistogramValueEncoder 

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

HistogramValueEncoder implements encoding of HistogramValue

func (*HistogramValueEncoder) CollectColumns 

func (e *HistogramValueEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*HistogramValueEncoder) Encode 

func (e *HistogramValueEncoder) Encode(val *HistogramValue)

Encode encodes val into buf

func (*HistogramValueEncoder) Init 

func (e *HistogramValueEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*HistogramValueEncoder) Reset 

func (e *HistogramValueEncoder) Reset()

type Int64Array 

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

Int64Array is a variable size array.

func (*Int64Array) Append 

func (e *Int64Array) Append(val int64)

Append a new element at the end of the array.

func (*Int64Array) At 

func (m *Int64Array) At(i int) int64

At returns element at index i.

func (*Int64Array) Clone 

func (e *Int64Array) Clone() Int64Array

Clone() creates a deep copy of Int64Array

func (*Int64Array) CopyFromSlice 

func (e *Int64Array) CopyFromSlice(src []int64)

CopyFromSlice copies from a slice into this array. The length of the array will be equal to the length of slice and elements of the array will be assigned from elements of the slice.

func (*Int64Array) EnsureLen 

func (e *Int64Array) EnsureLen(newLen int)

EnsureLen ensures the length of the array is equal to newLen. It will grow or shrink the array if needed.

func (*Int64Array) IsEqual 

func (e *Int64Array) IsEqual(val *Int64Array) bool

IsEqual performs deep comparison and returns true if array is equal to val.

func (*Int64Array) Len 

func (e *Int64Array) Len() int

Len returns the number of elements in the array.

type Int64ArrayDecoder 

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

func (*Int64ArrayDecoder) Continue 

func (d *Int64ArrayDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*Int64ArrayDecoder) Decode 

func (d *Int64ArrayDecoder) Decode(dst *Int64Array) error

func (*Int64ArrayDecoder) Init 

func (d *Int64ArrayDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*Int64ArrayDecoder) Reset 

func (d *Int64ArrayDecoder) Reset()

type Int64ArrayEncoder 

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

func (*Int64ArrayEncoder) CollectColumns 

func (e *Int64ArrayEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*Int64ArrayEncoder) Encode 

func (e *Int64ArrayEncoder) Encode(arr *Int64Array)

func (*Int64ArrayEncoder) Init 

func (e *Int64ArrayEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*Int64ArrayEncoder) Reset 

func (e *Int64ArrayEncoder) Reset()

type KeyValueList 

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

KeyValueList is a multimap, (aka an associative array or a list) of key value pairs from string to AnyValue.

func (*KeyValueList) At 

func (m *KeyValueList) At(i int) *KeyValueListElem

At returns element at index i.

func (*KeyValueList) Clone 

func (m *KeyValueList) Clone() KeyValueList

Clone() creates a deep copy of KeyValueList

func (*KeyValueList) CopyFrom 

func (m *KeyValueList) CopyFrom(src *KeyValueList)

func (*KeyValueList) EnsureLen 

func (m *KeyValueList) EnsureLen(newLen int)

EnsureLen ensures the length of the multimap is equal to newLen. It will grow or shrink the multimap if needed.

func (*KeyValueList) IsEqual 

func (e *KeyValueList) IsEqual(val *KeyValueList) bool

func (*KeyValueList) Len 

func (m *KeyValueList) Len() int

Len returns the number of elements in the multimap.

func (*KeyValueList) SetKey 

func (m *KeyValueList) SetKey(i int, k string)

SetKey sets the key of the element at index i.

func (*KeyValueList) Sort 

func (m *KeyValueList) Sort()

type KeyValueListDecoder 

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

func (*KeyValueListDecoder) Continue 

func (d *KeyValueListDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*KeyValueListDecoder) Decode 

func (d *KeyValueListDecoder) Decode(dst *KeyValueList) error

func (*KeyValueListDecoder) Init 

func (d *KeyValueListDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*KeyValueListDecoder) Reset 

func (d *KeyValueListDecoder) Reset()

type KeyValueListElem 

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

func (*KeyValueListElem) Key 

func (e *KeyValueListElem) Key() string

func (*KeyValueListElem) Value 

func (e *KeyValueListElem) Value() *AnyValue

type KeyValueListEncoder 

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

func (*KeyValueListEncoder) CollectColumns 

func (e *KeyValueListEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*KeyValueListEncoder) Encode 

func (e *KeyValueListEncoder) Encode(list *KeyValueList) (changed bool)

func (*KeyValueListEncoder) Init 

func (e *KeyValueListEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*KeyValueListEncoder) IsEqual 

func (e *KeyValueListEncoder) IsEqual(list *KeyValueList) bool

IsEqual performs deep comparison and returns true if encoder's previously encoded value is equal to list.

func (*KeyValueListEncoder) RencodeLast 

func (e *KeyValueListEncoder) RencodeLast()

func (*KeyValueListEncoder) Reset 

func (e *KeyValueListEncoder) Reset()
type Link struct {
	// contains filtered or unexported fields
}
func NewLink() *Link

func (*Link) Attributes 

func (s *Link) Attributes() *Attributes

func (*Link) CopyFrom 

func (s *Link) CopyFrom(src *Link)

CopyFrom() performs a deep copy from src.

func (*Link) Flags 

func (s *Link) Flags() uint64

func (*Link) Init 

func (s *Link) Init()

Init must be called once, before the Link is used.

func (*Link) IsAttributesModified 

func (s *Link) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Link was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Link) IsEqual 

func (e *Link) IsEqual(val *Link) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Link) IsFlagsModified 

func (s *Link) IsFlagsModified() bool

IsFlagsModified returns true the value of Flags field was modified since Link was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Link) IsSpanIDModified 

func (s *Link) IsSpanIDModified() bool

IsSpanIDModified returns true the value of SpanID field was modified since Link was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Link) IsTraceIDModified 

func (s *Link) IsTraceIDModified() bool

IsTraceIDModified returns true the value of TraceID field was modified since Link was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Link) IsTraceStateModified 

func (s *Link) IsTraceStateModified() bool

IsTraceStateModified returns true the value of TraceState field was modified since Link was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Link) SetFlags 

func (s *Link) SetFlags(v uint64)

SetFlags sets the value of Flags field.

func (*Link) SetSpanID 

func (s *Link) SetSpanID(v pkg.Bytes)

SetSpanID sets the value of SpanID field.

func (*Link) SetTraceID 

func (s *Link) SetTraceID(v pkg.Bytes)

SetTraceID sets the value of TraceID field.

func (*Link) SetTraceState 

func (s *Link) SetTraceState(v string)

SetTraceState sets the value of TraceState field.

func (*Link) SpanID 

func (s *Link) SpanID() pkg.Bytes

func (*Link) TraceID 

func (s *Link) TraceID() pkg.Bytes

func (*Link) TraceState 

func (s *Link) TraceState() string

type LinkArray 

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

LinkArray is a variable size array.

func (*LinkArray) Append 

func (e *LinkArray) Append(val *Link)

Append a new element at the end of the array.

func (*LinkArray) At 

func (m *LinkArray) At(i int) *Link

At returns element at index i.

func (*LinkArray) Clone 

func (e *LinkArray) Clone() LinkArray

Clone() creates a deep copy of LinkArray

func (*LinkArray) EnsureLen 

func (e *LinkArray) EnsureLen(newLen int)

EnsureLen ensures the length of the array is equal to newLen. It will grow or shrink the array if needed.

func (*LinkArray) IsEqual 

func (e *LinkArray) IsEqual(val *LinkArray) bool

IsEqual performs deep comparison and returns true if array is equal to val.

func (*LinkArray) Len 

func (e *LinkArray) Len() int

Len returns the number of elements in the array.

type LinkArrayDecoder 

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

func (*LinkArrayDecoder) Continue 

func (d *LinkArrayDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*LinkArrayDecoder) Decode 

func (d *LinkArrayDecoder) Decode(dst *LinkArray) error

func (*LinkArrayDecoder) Init 

func (d *LinkArrayDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*LinkArrayDecoder) Reset 

func (d *LinkArrayDecoder) Reset()

type LinkArrayEncoder 

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

func (*LinkArrayEncoder) CollectColumns 

func (e *LinkArrayEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

func (*LinkArrayEncoder) Encode 

func (e *LinkArrayEncoder) Encode(arr *LinkArray)

func (*LinkArrayEncoder) Init 

func (e *LinkArrayEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*LinkArrayEncoder) Reset 

func (e *LinkArrayEncoder) Reset()

type LinkDecoder 

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

LinkDecoder implements decoding of Link

func (*LinkDecoder) Continue 

func (d *LinkDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*LinkDecoder) Decode 

func (d *LinkDecoder) Decode(dstPtr *Link) error

func (*LinkDecoder) Init 

func (d *LinkDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*LinkDecoder) Reset 

func (d *LinkDecoder) Reset()

type LinkEncoder 

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

LinkEncoder implements encoding of Link

func (*LinkEncoder) CollectColumns 

func (e *LinkEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*LinkEncoder) Encode 

func (e *LinkEncoder) Encode(val *Link)

Encode encodes val into buf

func (*LinkEncoder) Init 

func (e *LinkEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*LinkEncoder) Reset 

func (e *LinkEncoder) Reset()

type Metric 

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

func NewMetric 

func NewMetric() *Metric

func (*Metric) AggregationTemporality 

func (s *Metric) AggregationTemporality() uint64

func (*Metric) Clone 

func (s *Metric) Clone() *Metric

func (*Metric) CopyFrom 

func (s *Metric) CopyFrom(src *Metric)

CopyFrom() performs a deep copy from src.

func (*Metric) Description 

func (s *Metric) Description() string

func (*Metric) HistogramBounds 

func (s *Metric) HistogramBounds() *Float64Array

func (*Metric) Init 

func (s *Metric) Init()

Init must be called once, before the Metric is used.

func (*Metric) IsAggregationTemporalityModified 

func (s *Metric) IsAggregationTemporalityModified() bool

IsAggregationTemporalityModified returns true the value of AggregationTemporality field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsDescriptionModified 

func (s *Metric) IsDescriptionModified() bool

IsDescriptionModified returns true the value of Description field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsEqual 

func (e *Metric) IsEqual(val *Metric) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Metric) IsHistogramBoundsModified 

func (s *Metric) IsHistogramBoundsModified() bool

IsHistogramBoundsModified returns true the value of HistogramBounds field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsMetadataModified 

func (s *Metric) IsMetadataModified() bool

IsMetadataModified returns true the value of Metadata field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsMonotonicModified 

func (s *Metric) IsMonotonicModified() bool

IsMonotonicModified returns true the value of Monotonic field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsNameModified 

func (s *Metric) IsNameModified() bool

IsNameModified returns true the value of Name field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsTypeModified 

func (s *Metric) IsTypeModified() bool

IsTypeModified returns true the value of Type field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) IsUnitModified 

func (s *Metric) IsUnitModified() bool

IsUnitModified returns true the value of Unit field was modified since Metric was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metric) Metadata 

func (s *Metric) Metadata() *Attributes

func (*Metric) Monotonic 

func (s *Metric) Monotonic() bool

func (*Metric) Name 

func (s *Metric) Name() string

func (*Metric) SetAggregationTemporality 

func (s *Metric) SetAggregationTemporality(v uint64)

SetAggregationTemporality sets the value of AggregationTemporality field.

func (*Metric) SetDescription 

func (s *Metric) SetDescription(v string)

SetDescription sets the value of Description field.

func (*Metric) SetMonotonic 

func (s *Metric) SetMonotonic(v bool)

SetMonotonic sets the value of Monotonic field.

func (*Metric) SetName 

func (s *Metric) SetName(v string)

SetName sets the value of Name field.

func (*Metric) SetType 

func (s *Metric) SetType(v uint64)

SetType sets the value of Type field.

func (*Metric) SetUnit 

func (s *Metric) SetUnit(v string)

SetUnit sets the value of Unit field.

func (*Metric) Type 

func (s *Metric) Type() uint64

func (*Metric) Unit 

func (s *Metric) Unit() string

type MetricDecoder 

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

MetricDecoder implements decoding of Metric

func (*MetricDecoder) Continue 

func (d *MetricDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*MetricDecoder) Decode 

func (d *MetricDecoder) Decode(dstPtr **Metric) error

func (*MetricDecoder) Init 

func (d *MetricDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*MetricDecoder) Reset 

func (d *MetricDecoder) Reset()

type MetricDecoderDict 

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

MetricDecoderDict is the dictionary used by MetricDecoder

func (*MetricDecoderDict) Init 

func (d *MetricDecoderDict) Init()

type MetricEncoder 

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

MetricEncoder implements encoding of Metric

func (*MetricEncoder) CollectColumns 

func (e *MetricEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*MetricEncoder) Encode 

func (e *MetricEncoder) Encode(val *Metric)

Encode encodes val into buf

func (*MetricEncoder) Init 

func (e *MetricEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*MetricEncoder) Reset 

func (e *MetricEncoder) Reset()

type MetricEncoderDict 

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

MetricEncoderDict is the dictionary used by MetricEncoder

func (*MetricEncoderDict) Init 

func (d *MetricEncoderDict) Init(limiter *pkg.SizeLimiter)

func (*MetricEncoderDict) Reset 

func (d *MetricEncoderDict) Reset()

type MetricEntry 

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

type MetricFlags 

type MetricFlags uint

MetricFlags is a bitmask 

const (
	MetricMonotonic              MetricFlags = 0b001
	MetricTemporalityMask        MetricFlags = 0b110
	MetricTemporalityUnspecified MetricFlags = 0b000
	MetricTemporalityDelta       MetricFlags = 0b010
	MetricTemporalityCumulative  MetricFlags = 0b100
)

type MetricType 

type MetricType uint
const (
	Gauge MetricType = iota
	Sum
	Histogram
	ExpHistogram
	Summary
	MetricTypeLimit
)

type Metrics 

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

func NewMetrics 

func NewMetrics() *Metrics

func (*Metrics) Attributes 

func (s *Metrics) Attributes() *Attributes

func (*Metrics) CopyFrom 

func (s *Metrics) CopyFrom(src *Metrics)

CopyFrom() performs a deep copy from src.

func (*Metrics) Envelope 

func (s *Metrics) Envelope() *Envelope

func (*Metrics) Init 

func (s *Metrics) Init()

Init must be called once, before the Metrics is used.

func (*Metrics) IsAttributesModified 

func (s *Metrics) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Metrics was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metrics) IsEnvelopeModified 

func (s *Metrics) IsEnvelopeModified() bool

IsEnvelopeModified returns true the value of Envelope field was modified since Metrics was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metrics) IsEqual 

func (e *Metrics) IsEqual(val *Metrics) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Metrics) IsMetricModified 

func (s *Metrics) IsMetricModified() bool

IsMetricModified returns true the value of Metric field was modified since Metrics was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metrics) IsPointModified 

func (s *Metrics) IsPointModified() bool

IsPointModified returns true the value of Point field was modified since Metrics was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metrics) IsResourceModified 

func (s *Metrics) IsResourceModified() bool

IsResourceModified returns true the value of Resource field was modified since Metrics was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metrics) IsScopeModified 

func (s *Metrics) IsScopeModified() bool

IsScopeModified returns true the value of Scope field was modified since Metrics was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Metrics) Metric 

func (s *Metrics) Metric() *Metric

func (*Metrics) Point 

func (s *Metrics) Point() *Point

func (*Metrics) Resource 

func (s *Metrics) Resource() *Resource

func (*Metrics) Scope 

func (s *Metrics) Scope() *Scope

type MetricsDecoder 

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

MetricsDecoder implements decoding of Metrics

func (*MetricsDecoder) Continue 

func (d *MetricsDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*MetricsDecoder) Decode 

func (d *MetricsDecoder) Decode(dstPtr *Metrics) error

func (*MetricsDecoder) Init 

func (d *MetricsDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*MetricsDecoder) Reset 

func (d *MetricsDecoder) Reset()

type MetricsEncoder 

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

MetricsEncoder implements encoding of Metrics

func (*MetricsEncoder) CollectColumns 

func (e *MetricsEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*MetricsEncoder) Encode 

func (e *MetricsEncoder) Encode(val *Metrics)

Encode encodes val into buf

func (*MetricsEncoder) Init 

func (e *MetricsEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*MetricsEncoder) Reset 

func (e *MetricsEncoder) Reset()

type MetricsReader 

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

func NewMetricsReader 

func NewMetricsReader(source io.Reader) (*MetricsReader, error)

func (*MetricsReader) Header 

func (f *MetricsReader) Header() *pkg.FixedHeader

func (*MetricsReader) Read 

func (r *MetricsReader) Read() (*Metrics, error)

func (*MetricsReader) RecordCount 

func (r *MetricsReader) RecordCount() uint64

func (*MetricsReader) UserData 

func (f *MetricsReader) UserData() map[string]any

type MetricsWriter 

type MetricsWriter struct {
	Record Metrics
	// contains filtered or unexported fields
}

func NewMetricsWriter 

func NewMetricsWriter(dst pkg.ChunkWriter, opts pkg.WriterOptions) (*MetricsWriter, error)

func (*MetricsWriter) Flush 

func (w *MetricsWriter) Flush() error

func (*MetricsWriter) RecordCount 

func (w *MetricsWriter) RecordCount() uint64

func (*MetricsWriter) Write 

func (w *MetricsWriter) Write() error

type Point 

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

func NewPoint 

func NewPoint() *Point

func (*Point) CopyFrom 

func (s *Point) CopyFrom(src *Point)

CopyFrom() performs a deep copy from src.

func (*Point) Exemplars 

func (s *Point) Exemplars() *ExemplarArray

func (*Point) Init 

func (s *Point) Init()

Init must be called once, before the Point is used.

func (*Point) IsEqual 

func (e *Point) IsEqual(val *Point) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Point) IsExemplarsModified 

func (s *Point) IsExemplarsModified() bool

IsExemplarsModified returns true the value of Exemplars field was modified since Point was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Point) IsStartTimestampModified 

func (s *Point) IsStartTimestampModified() bool

IsStartTimestampModified returns true the value of StartTimestamp field was modified since Point was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Point) IsTimestampModified 

func (s *Point) IsTimestampModified() bool

IsTimestampModified returns true the value of Timestamp field was modified since Point was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Point) IsValueModified 

func (s *Point) IsValueModified() bool

IsValueModified returns true the value of Value field was modified since Point was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Point) SetStartTimestamp 

func (s *Point) SetStartTimestamp(v uint64)

SetStartTimestamp sets the value of StartTimestamp field.

func (*Point) SetTimestamp 

func (s *Point) SetTimestamp(v uint64)

SetTimestamp sets the value of Timestamp field.

func (*Point) StartTimestamp 

func (s *Point) StartTimestamp() uint64

func (*Point) Timestamp 

func (s *Point) Timestamp() uint64

func (*Point) Value 

func (s *Point) Value() *PointValue

type PointDecoder 

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

PointDecoder implements decoding of Point

func (*PointDecoder) Continue 

func (d *PointDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*PointDecoder) Decode 

func (d *PointDecoder) Decode(dstPtr *Point) error

func (*PointDecoder) Init 

func (d *PointDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*PointDecoder) Reset 

func (d *PointDecoder) Reset()

type PointEncoder 

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

PointEncoder implements encoding of Point

func (*PointEncoder) CollectColumns 

func (e *PointEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*PointEncoder) Encode 

func (e *PointEncoder) Encode(val *Point)

Encode encodes val into buf

func (*PointEncoder) Init 

func (e *PointEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*PointEncoder) Reset 

func (e *PointEncoder) Reset()

type PointValue 

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

PointValue is a oneof struct.

func (*PointValue) CopyFrom 

func (s *PointValue) CopyFrom(src *PointValue)

CopyFrom() performs a deep copy from src.

func (*PointValue) Float64 

func (s *PointValue) Float64() float64

Float64 returns the value if the contained type is currently PointValueTypeFloat64. The caller must check the type via Type() before attempting to call this function.

func (*PointValue) Histogram 

func (s *PointValue) Histogram() *HistogramValue

Histogram returns the value if the contained type is currently PointValueTypeHistogram. The caller must check the type via Type() before attempting to call this function.

func (*PointValue) Init 

func (s *PointValue) Init()

Init must be called once, before the PointValue is used.

func (*PointValue) Int64 

func (s *PointValue) Int64() int64

Int64 returns the value if the contained type is currently PointValueTypeInt64. The caller must check the type via Type() before attempting to call this function.

func (*PointValue) IsEqual 

func (e *PointValue) IsEqual(val *PointValue) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*PointValue) SetFloat64 

func (s *PointValue) SetFloat64(v float64)

SetFloat64 sets the value to the specified value and sets the type to PointValueTypeFloat64.

func (*PointValue) SetInt64 

func (s *PointValue) SetInt64(v int64)

SetInt64 sets the value to the specified value and sets the type to PointValueTypeInt64.

func (*PointValue) SetType 

func (s *PointValue) SetType(typ PointValueType)

SetType sets the type of the value currently contained in PointValue.

func (*PointValue) Type 

func (s *PointValue) Type() PointValueType

Type returns the type of the value currently contained in PointValue.

type PointValueDecoder 

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

PointValueDecoder implements decoding of PointValue

func (*PointValueDecoder) Continue 

func (d *PointValueDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*PointValueDecoder) Decode 

func (d *PointValueDecoder) Decode(dstPtr *PointValue) error

func (*PointValueDecoder) Init 

func (d *PointValueDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*PointValueDecoder) Reset 

func (d *PointValueDecoder) Reset()

type PointValueEncoder 

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

PointValueEncoder implements encoding of PointValue

func (*PointValueEncoder) CollectColumns 

func (e *PointValueEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*PointValueEncoder) Encode 

func (e *PointValueEncoder) Encode(val *PointValue)

Encode encodes val into buf

func (*PointValueEncoder) Init 

func (e *PointValueEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*PointValueEncoder) Reset 

func (e *PointValueEncoder) Reset()

type PointValueType 

type PointValueType byte

type ReaderState 

type ReaderState struct {
	// OverrideSchema is set if decoding should perform a translation from specfied
	// schema. OverrideSchema must be compatible with decoders' schema.
	OverrideSchema *schema.Schema

	// Dictionaries
	AnyValueString    encoders.StringDecoderDict
	AttributeKey      encoders.StringDecoderDict
	Metric            MetricDecoderDict
	MetricDescription encoders.StringDecoderDict
	MetricName        encoders.StringDecoderDict
	MetricUnit        encoders.StringDecoderDict
	Resource          ResourceDecoderDict
	SchemaURL         encoders.StringDecoderDict
	Scope             ScopeDecoderDict
	ScopeName         encoders.StringDecoderDict
	ScopeVersion      encoders.StringDecoderDict
	Span              encoders.BytesDecoderDict
	SpanEventName     encoders.StringDecoderDict
	SpanName          encoders.StringDecoderDict
	Trace             encoders.BytesDecoderDict

	// Decoders
	AnyValueDecoder           *AnyValueDecoder
	AnyValueArrayDecoder      *AnyValueArrayDecoder
	AttributesDecoder         *AttributesDecoder
	EnvelopeDecoder           *EnvelopeDecoder
	EnvelopeAttributesDecoder *EnvelopeAttributesDecoder
	EventDecoder              *EventDecoder
	EventArrayDecoder         *EventArrayDecoder
	ExemplarDecoder           *ExemplarDecoder
	ExemplarArrayDecoder      *ExemplarArrayDecoder
	ExemplarValueDecoder      *ExemplarValueDecoder
	Float64ArrayDecoder       *Float64ArrayDecoder
	HistogramValueDecoder     *HistogramValueDecoder
	Int64ArrayDecoder         *Int64ArrayDecoder
	KeyValueListDecoder       *KeyValueListDecoder
	LinkDecoder               *LinkDecoder
	LinkArrayDecoder          *LinkArrayDecoder
	MetricDecoder             *MetricDecoder
	MetricsDecoder            *MetricsDecoder
	PointDecoder              *PointDecoder
	PointValueDecoder         *PointValueDecoder
	ResourceDecoder           *ResourceDecoder
	ScopeDecoder              *ScopeDecoder
	SpanDecoder               *SpanDecoder
	SpanStatusDecoder         *SpanStatusDecoder
	SpansDecoder              *SpansDecoder
}

func (*ReaderState) Init 

func (d *ReaderState) Init(overrideSchema *schema.Schema)

type Resource 

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

func NewResource 

func NewResource() *Resource

func (*Resource) Attributes 

func (s *Resource) Attributes() *Attributes

func (*Resource) Clone 

func (s *Resource) Clone() *Resource

func (*Resource) CopyFrom 

func (s *Resource) CopyFrom(src *Resource)

CopyFrom() performs a deep copy from src.

func (*Resource) Init 

func (s *Resource) Init()

Init must be called once, before the Resource is used.

func (*Resource) IsAttributesModified 

func (s *Resource) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Resource was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Resource) IsEqual 

func (e *Resource) IsEqual(val *Resource) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Resource) IsSchemaURLModified 

func (s *Resource) IsSchemaURLModified() bool

IsSchemaURLModified returns true the value of SchemaURL field was modified since Resource was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Resource) SchemaURL 

func (s *Resource) SchemaURL() string

func (*Resource) SetSchemaURL 

func (s *Resource) SetSchemaURL(v string)

SetSchemaURL sets the value of SchemaURL field.

type ResourceDecoder 

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

ResourceDecoder implements decoding of Resource

func (*ResourceDecoder) Continue 

func (d *ResourceDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*ResourceDecoder) Decode 

func (d *ResourceDecoder) Decode(dstPtr **Resource) error

func (*ResourceDecoder) Init 

func (d *ResourceDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*ResourceDecoder) Reset 

func (d *ResourceDecoder) Reset()

type ResourceDecoderDict 

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

ResourceDecoderDict is the dictionary used by ResourceDecoder

func (*ResourceDecoderDict) Init 

func (d *ResourceDecoderDict) Init()

type ResourceEncoder 

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

ResourceEncoder implements encoding of Resource

func (*ResourceEncoder) CollectColumns 

func (e *ResourceEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*ResourceEncoder) Encode 

func (e *ResourceEncoder) Encode(val *Resource)

Encode encodes val into buf

func (*ResourceEncoder) Init 

func (e *ResourceEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*ResourceEncoder) Reset 

func (e *ResourceEncoder) Reset()

type ResourceEncoderDict 

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

ResourceEncoderDict is the dictionary used by ResourceEncoder

func (*ResourceEncoderDict) Init 

func (d *ResourceEncoderDict) Init(limiter *pkg.SizeLimiter)

func (*ResourceEncoderDict) Reset 

func (d *ResourceEncoderDict) Reset()

type ResourceEntry 

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

type Scope 

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

func NewScope 

func NewScope() *Scope

func (*Scope) Attributes 

func (s *Scope) Attributes() *Attributes

func (*Scope) Clone 

func (s *Scope) Clone() *Scope

func (*Scope) CopyFrom 

func (s *Scope) CopyFrom(src *Scope)

CopyFrom() performs a deep copy from src.

func (*Scope) Init 

func (s *Scope) Init()

Init must be called once, before the Scope is used.

func (*Scope) IsAttributesModified 

func (s *Scope) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Scope was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Scope) IsEqual 

func (e *Scope) IsEqual(val *Scope) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Scope) IsNameModified 

func (s *Scope) IsNameModified() bool

IsNameModified returns true the value of Name field was modified since Scope was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Scope) IsSchemaURLModified 

func (s *Scope) IsSchemaURLModified() bool

IsSchemaURLModified returns true the value of SchemaURL field was modified since Scope was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Scope) IsVersionModified 

func (s *Scope) IsVersionModified() bool

IsVersionModified returns true the value of Version field was modified since Scope was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Scope) Name 

func (s *Scope) Name() string

func (*Scope) SchemaURL 

func (s *Scope) SchemaURL() string

func (*Scope) SetName 

func (s *Scope) SetName(v string)

SetName sets the value of Name field.

func (*Scope) SetSchemaURL 

func (s *Scope) SetSchemaURL(v string)

SetSchemaURL sets the value of SchemaURL field.

func (*Scope) SetVersion 

func (s *Scope) SetVersion(v string)

SetVersion sets the value of Version field.

func (*Scope) Version 

func (s *Scope) Version() string

type ScopeDecoder 

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

ScopeDecoder implements decoding of Scope

func (*ScopeDecoder) Continue 

func (d *ScopeDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*ScopeDecoder) Decode 

func (d *ScopeDecoder) Decode(dstPtr **Scope) error

func (*ScopeDecoder) Init 

func (d *ScopeDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*ScopeDecoder) Reset 

func (d *ScopeDecoder) Reset()

type ScopeDecoderDict 

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

ScopeDecoderDict is the dictionary used by ScopeDecoder

func (*ScopeDecoderDict) Init 

func (d *ScopeDecoderDict) Init()

type ScopeEncoder 

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

ScopeEncoder implements encoding of Scope

func (*ScopeEncoder) CollectColumns 

func (e *ScopeEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*ScopeEncoder) Encode 

func (e *ScopeEncoder) Encode(val *Scope)

Encode encodes val into buf

func (*ScopeEncoder) Init 

func (e *ScopeEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*ScopeEncoder) Reset 

func (e *ScopeEncoder) Reset()

type ScopeEncoderDict 

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

ScopeEncoderDict is the dictionary used by ScopeEncoder

func (*ScopeEncoderDict) Init 

func (d *ScopeEncoderDict) Init(limiter *pkg.SizeLimiter)

func (*ScopeEncoderDict) Reset 

func (d *ScopeEncoderDict) Reset()

type ScopeEntry 

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

type Span 

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

func NewSpan 

func NewSpan() *Span

func (*Span) Attributes 

func (s *Span) Attributes() *Attributes

func (*Span) CopyFrom 

func (s *Span) CopyFrom(src *Span)

CopyFrom() performs a deep copy from src.

func (*Span) EndTimeUnixNano 

func (s *Span) EndTimeUnixNano() uint64

func (*Span) Events 

func (s *Span) Events() *EventArray

func (*Span) Flags 

func (s *Span) Flags() uint64

func (*Span) Init 

func (s *Span) Init()

Init must be called once, before the Span is used.

func (*Span) IsAttributesModified 

func (s *Span) IsAttributesModified() bool

IsAttributesModified returns true the value of Attributes field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsEndTimeUnixNanoModified 

func (s *Span) IsEndTimeUnixNanoModified() bool

IsEndTimeUnixNanoModified returns true the value of EndTimeUnixNano field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsEqual 

func (e *Span) IsEqual(val *Span) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Span) IsEventsModified 

func (s *Span) IsEventsModified() bool

IsEventsModified returns true the value of Events field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsFlagsModified 

func (s *Span) IsFlagsModified() bool

IsFlagsModified returns true the value of Flags field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsKindModified 

func (s *Span) IsKindModified() bool

IsKindModified returns true the value of Kind field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsLinksModified 

func (s *Span) IsLinksModified() bool

IsLinksModified returns true the value of Links field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsNameModified 

func (s *Span) IsNameModified() bool

IsNameModified returns true the value of Name field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsParentSpanIDModified 

func (s *Span) IsParentSpanIDModified() bool

IsParentSpanIDModified returns true the value of ParentSpanID field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsSpanIDModified 

func (s *Span) IsSpanIDModified() bool

IsSpanIDModified returns true the value of SpanID field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsStartTimeUnixNanoModified 

func (s *Span) IsStartTimeUnixNanoModified() bool

IsStartTimeUnixNanoModified returns true the value of StartTimeUnixNano field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsStatusModified 

func (s *Span) IsStatusModified() bool

IsStatusModified returns true the value of Status field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsTraceIDModified 

func (s *Span) IsTraceIDModified() bool

IsTraceIDModified returns true the value of TraceID field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) IsTraceStateModified 

func (s *Span) IsTraceStateModified() bool

IsTraceStateModified returns true the value of TraceState field was modified since Span was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Span) Kind 

func (s *Span) Kind() uint64
func (s *Span) Links() *LinkArray

func (*Span) Name 

func (s *Span) Name() string

func (*Span) ParentSpanID 

func (s *Span) ParentSpanID() pkg.Bytes

func (*Span) SetEndTimeUnixNano 

func (s *Span) SetEndTimeUnixNano(v uint64)

SetEndTimeUnixNano sets the value of EndTimeUnixNano field.

func (*Span) SetFlags 

func (s *Span) SetFlags(v uint64)

SetFlags sets the value of Flags field.

func (*Span) SetKind 

func (s *Span) SetKind(v uint64)

SetKind sets the value of Kind field.

func (*Span) SetName 

func (s *Span) SetName(v string)

SetName sets the value of Name field.

func (*Span) SetParentSpanID 

func (s *Span) SetParentSpanID(v pkg.Bytes)

SetParentSpanID sets the value of ParentSpanID field.

func (*Span) SetSpanID 

func (s *Span) SetSpanID(v pkg.Bytes)

SetSpanID sets the value of SpanID field.

func (*Span) SetStartTimeUnixNano 

func (s *Span) SetStartTimeUnixNano(v uint64)

SetStartTimeUnixNano sets the value of StartTimeUnixNano field.

func (*Span) SetTraceID 

func (s *Span) SetTraceID(v pkg.Bytes)

SetTraceID sets the value of TraceID field.

func (*Span) SetTraceState 

func (s *Span) SetTraceState(v string)

SetTraceState sets the value of TraceState field.

func (*Span) SpanID 

func (s *Span) SpanID() pkg.Bytes

func (*Span) StartTimeUnixNano 

func (s *Span) StartTimeUnixNano() uint64

func (*Span) Status 

func (s *Span) Status() *SpanStatus

func (*Span) TraceID 

func (s *Span) TraceID() pkg.Bytes

func (*Span) TraceState 

func (s *Span) TraceState() string

type SpanDecoder 

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

SpanDecoder implements decoding of Span

func (*SpanDecoder) Continue 

func (d *SpanDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*SpanDecoder) Decode 

func (d *SpanDecoder) Decode(dstPtr *Span) error

func (*SpanDecoder) Init 

func (d *SpanDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*SpanDecoder) Reset 

func (d *SpanDecoder) Reset()

type SpanEncoder 

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

SpanEncoder implements encoding of Span

func (*SpanEncoder) CollectColumns 

func (e *SpanEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*SpanEncoder) Encode 

func (e *SpanEncoder) Encode(val *Span)

Encode encodes val into buf

func (*SpanEncoder) Init 

func (e *SpanEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*SpanEncoder) Reset 

func (e *SpanEncoder) Reset()

type SpanStatus 

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

func NewSpanStatus 

func NewSpanStatus() *SpanStatus

func (*SpanStatus) Code 

func (s *SpanStatus) Code() uint64

func (*SpanStatus) CopyFrom 

func (s *SpanStatus) CopyFrom(src *SpanStatus)

CopyFrom() performs a deep copy from src.

func (*SpanStatus) Init 

func (s *SpanStatus) Init()

Init must be called once, before the SpanStatus is used.

func (*SpanStatus) IsCodeModified 

func (s *SpanStatus) IsCodeModified() bool

IsCodeModified returns true the value of Code field was modified since SpanStatus was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*SpanStatus) IsEqual 

func (e *SpanStatus) IsEqual(val *SpanStatus) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*SpanStatus) IsMessageModified 

func (s *SpanStatus) IsMessageModified() bool

IsMessageModified returns true the value of Message field was modified since SpanStatus was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*SpanStatus) Message 

func (s *SpanStatus) Message() string

func (*SpanStatus) SetCode 

func (s *SpanStatus) SetCode(v uint64)

SetCode sets the value of Code field.

func (*SpanStatus) SetMessage 

func (s *SpanStatus) SetMessage(v string)

SetMessage sets the value of Message field.

type SpanStatusDecoder 

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

SpanStatusDecoder implements decoding of SpanStatus

func (*SpanStatusDecoder) Continue 

func (d *SpanStatusDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*SpanStatusDecoder) Decode 

func (d *SpanStatusDecoder) Decode(dstPtr *SpanStatus) error

func (*SpanStatusDecoder) Init 

func (d *SpanStatusDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*SpanStatusDecoder) Reset 

func (d *SpanStatusDecoder) Reset()

type SpanStatusEncoder 

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

SpanStatusEncoder implements encoding of SpanStatus

func (*SpanStatusEncoder) CollectColumns 

func (e *SpanStatusEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*SpanStatusEncoder) Encode 

func (e *SpanStatusEncoder) Encode(val *SpanStatus)

Encode encodes val into buf

func (*SpanStatusEncoder) Init 

func (e *SpanStatusEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*SpanStatusEncoder) Reset 

func (e *SpanStatusEncoder) Reset()

type Spans 

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

func NewSpans 

func NewSpans() *Spans

func (*Spans) CopyFrom 

func (s *Spans) CopyFrom(src *Spans)

CopyFrom() performs a deep copy from src.

func (*Spans) Envelope 

func (s *Spans) Envelope() *Envelope

func (*Spans) Init 

func (s *Spans) Init()

Init must be called once, before the Spans is used.

func (*Spans) IsEnvelopeModified 

func (s *Spans) IsEnvelopeModified() bool

IsEnvelopeModified returns true the value of Envelope field was modified since Spans was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Spans) IsEqual 

func (e *Spans) IsEqual(val *Spans) bool

IsEqual performs deep comparison and returns true if struct is equal to val.

func (*Spans) IsResourceModified 

func (s *Spans) IsResourceModified() bool

IsResourceModified returns true the value of Resource field was modified since Spans was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Spans) IsScopeModified 

func (s *Spans) IsScopeModified() bool

IsScopeModified returns true the value of Scope field was modified since Spans was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Spans) IsSpanModified 

func (s *Spans) IsSpanModified() bool

IsSpanModified returns true the value of Span field was modified since Spans was created, encoded or decoded. If the field is modified it will be encoded by the next Write() operation. If the field is decoded by the next Read() operation the modified flag will be set.

func (*Spans) Resource 

func (s *Spans) Resource() *Resource

func (*Spans) Scope 

func (s *Spans) Scope() *Scope

func (*Spans) Span 

func (s *Spans) Span() *Span

type SpansDecoder 

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

SpansDecoder implements decoding of Spans

func (*SpansDecoder) Continue 

func (d *SpansDecoder) Continue()

Continue is called at the start of the frame to continue decoding column data. This should set the decoder's source buffer, so the new decoding continues from the supplied column data. This should NOT reset the internal state of the decoder, since columns can cross frame boundaries and the new column data is considered continuation of that same column in the previous frame.

func (*SpansDecoder) Decode 

func (d *SpansDecoder) Decode(dstPtr *Spans) error

func (*SpansDecoder) Init 

func (d *SpansDecoder) Init(state *ReaderState, columns *pkg.ReadColumnSet) error

Init is called once in the lifetime of the stream.

func (*SpansDecoder) Reset 

func (d *SpansDecoder) Reset()

type SpansEncoder 

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

SpansEncoder implements encoding of Spans

func (*SpansEncoder) CollectColumns 

func (e *SpansEncoder) CollectColumns(columnSet *pkg.WriteColumnSet)

CollectColumns collects all buffers from all encoders into buf.

func (*SpansEncoder) Encode 

func (e *SpansEncoder) Encode(val *Spans)

Encode encodes val into buf

func (*SpansEncoder) Init 

func (e *SpansEncoder) Init(state *WriterState, columns *pkg.WriteColumnSet) error

func (*SpansEncoder) Reset 

func (e *SpansEncoder) Reset()

type SpansReader 

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

func NewSpansReader 

func NewSpansReader(source io.Reader) (*SpansReader, error)

func (*SpansReader) Header 

func (f *SpansReader) Header() *pkg.FixedHeader

func (*SpansReader) Read 

func (r *SpansReader) Read() (*Spans, error)

func (*SpansReader) RecordCount 

func (r *SpansReader) RecordCount() uint64

func (*SpansReader) UserData 

func (f *SpansReader) UserData() map[string]any

type SpansWriter 

type SpansWriter struct {
	Record Spans
	// contains filtered or unexported fields
}

func NewSpansWriter 

func NewSpansWriter(dst pkg.ChunkWriter, opts pkg.WriterOptions) (*SpansWriter, error)

func (*SpansWriter) Flush 

func (w *SpansWriter) Flush() error

func (*SpansWriter) RecordCount 

func (w *SpansWriter) RecordCount() uint64

func (*SpansWriter) Write 

func (w *SpansWriter) Write() error

type WriterState 

type WriterState struct {

	// OverrideSchema is set if encoding should perform a translation into the target
	// schema. The specified schema must be compatible with endoders' schema.
	OverrideSchema *schema.Schema

	// Dictionaries
	AnyValueString    encoders.StringEncoderDict
	AttributeKey      encoders.StringEncoderDict
	Metric            MetricEncoderDict
	MetricDescription encoders.StringEncoderDict
	MetricName        encoders.StringEncoderDict
	MetricUnit        encoders.StringEncoderDict
	Resource          ResourceEncoderDict
	SchemaURL         encoders.StringEncoderDict
	Scope             ScopeEncoderDict
	ScopeName         encoders.StringEncoderDict
	ScopeVersion      encoders.StringEncoderDict
	Span              encoders.BytesEncoderDict
	SpanEventName     encoders.StringEncoderDict
	SpanName          encoders.StringEncoderDict
	Trace             encoders.BytesEncoderDict

	// Encoders
	AnyValueEncoder           *AnyValueEncoder
	AnyValueArrayEncoder      *AnyValueArrayEncoder
	AttributesEncoder         *AttributesEncoder
	EnvelopeEncoder           *EnvelopeEncoder
	EnvelopeAttributesEncoder *EnvelopeAttributesEncoder
	EventEncoder              *EventEncoder
	EventArrayEncoder         *EventArrayEncoder
	ExemplarEncoder           *ExemplarEncoder
	ExemplarArrayEncoder      *ExemplarArrayEncoder
	ExemplarValueEncoder      *ExemplarValueEncoder
	Float64ArrayEncoder       *Float64ArrayEncoder
	HistogramValueEncoder     *HistogramValueEncoder
	Int64ArrayEncoder         *Int64ArrayEncoder
	KeyValueListEncoder       *KeyValueListEncoder
	LinkEncoder               *LinkEncoder
	LinkArrayEncoder          *LinkArrayEncoder
	MetricEncoder             *MetricEncoder
	MetricsEncoder            *MetricsEncoder
	PointEncoder              *PointEncoder
	PointValueEncoder         *PointValueEncoder
	ResourceEncoder           *ResourceEncoder
	ScopeEncoder              *ScopeEncoder
	SpanEncoder               *SpanEncoder
	SpanStatusEncoder         *SpanStatusEncoder
	SpansEncoder              *SpansEncoder
	// contains filtered or unexported fields
}

func (*WriterState) Init 

func (d *WriterState) Init(opts *pkg.WriterOptions)

func (*WriterState) Reset 

func (d *WriterState) Reset()

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.