merger

Feb 27, 2025

Changes in this version

type Value

+ func (s *Value) AppendBinary(b []byte) ([]byte, error)

Jan 16, 2025

Changes in this version

type Key

+ Metadata []KeyValues

+ func (k *Key) AppendBinary(b []byte) ([]byte, error)

+ type KeyValues struct

+ Key string

+ Values []string

type Value

+ func NewValue(resLimit, scopeLimit, metricLimit, datapointLimit config.LimitConfig) *Value

+ func (s *Value) Finalize() (pmetric.Metrics, error)

+ func (s *Value) Marshal() ([]byte, error)

+ func (s *Value) Unmarshal(data []byte) error

Oct 4, 2024

Changes in this version

+ type DataPoint interface

+ Attributes func() pcommon.Map

+ CopyTo func(dest Self)

+ SetTimestamp func(pcommon.Timestamp)

+ Timestamp func() pcommon.Timestamp

+ type DataPointSlice interface

+ AppendEmpty func() DP

+ At func(i int) DP

+ Len func() int

+ type Key struct

+ Interval time.Duration

+ ProcessingTime time.Time

+ func NewKey(ivl time.Duration, pTime time.Time) Key

+ func (k *Key) Marshal() ([]byte, error)

+ func (k *Key) SizeBinary() int

+ func (k *Key) Unmarshal(d []byte) error

+ type Merger struct

+ func New(v Value) *Merger

+ func (m *Merger) Finish(includesBase bool) ([]byte, io.Closer, error)

+ func (m *Merger) MergeNewer(value []byte) error

+ func (m *Merger) MergeOlder(value []byte) error

+ type Value struct

+ Metrics pmetric.Metrics

+ func (v *Value) MarshalProto() ([]byte, error)

+ func (v *Value) Merge(op Value) error

+ func (v *Value) MergeMetric(rm pmetric.ResourceMetrics, sm pmetric.ScopeMetrics, m pmetric.Metric)

+ func (v *Value) SizeBinary() int

+ func (v *Value) UnmarshalProto(data []byte) (err error)