mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-11-03 02:20:04 +00:00
zeekay
7baf52d980
- Fix 'Hanzo O11y' (space) → 'HanzoO11y' in Go struct/func names - Package o11yclickhousemetrics → o11ydatastoremetrics (matches dir) - Package o11yclickhousemeter → o11ydatastoremeter (matches dir) - Import paths aligned with actual directory structure - Component type names kept as signozclickhousemetrics for config compat
68 lines
2.0 KiB
Go
68 lines
2.0 KiB
Go
package o11ydatastoremetrics
|
|
|
|
import (
|
|
"math"
|
|
"time"
|
|
|
|
pkgfingerprint "github.com/hanzoai/otel-collector/internal/common/fingerprint"
|
|
"go.opentelemetry.io/collector/pdata/pmetric"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
type batch struct {
|
|
samples []*sample
|
|
expHist []*exponentialHistogramSample
|
|
ts []*ts
|
|
metadata []*metadata
|
|
logger *zap.Logger
|
|
}
|
|
|
|
func newBatch(logger *zap.Logger) *batch {
|
|
return &batch{
|
|
samples: make([]*sample, 0),
|
|
expHist: make([]*exponentialHistogramSample, 0),
|
|
ts: make([]*ts, 0),
|
|
metadata: make([]*metadata, 0),
|
|
logger: logger,
|
|
}
|
|
}
|
|
|
|
func (b *batch) addMetadata(name, desc, unit string, typ pmetric.MetricType, temporality pmetric.AggregationTemporality, isMonotonic bool, fingerprint *pkgfingerprint.Fingerprint, firstSeenUnixMilli, lastSeenUnixMilli int64) {
|
|
|
|
if firstSeenUnixMilli == int64(math.MaxInt64) { // which means they were never set because of zero samples, default to now
|
|
now := time.Now().UnixMilli()
|
|
firstSeenUnixMilli = now
|
|
lastSeenUnixMilli = now
|
|
b.logger.Debug("firstSeen/lastSeen not provided; defaulting to now", zap.Int64("first_seen_unix_milli", firstSeenUnixMilli), zap.Int64("last_seen_unix_milli", lastSeenUnixMilli))
|
|
}
|
|
|
|
for key, value := range fingerprint.Attributes() {
|
|
b.metadata = append(b.metadata, &metadata{
|
|
metricName: name,
|
|
temporality: temporality,
|
|
description: desc,
|
|
unit: unit,
|
|
typ: typ,
|
|
isMonotonic: isMonotonic,
|
|
attrName: key,
|
|
attrType: fingerprint.Type().String(),
|
|
attrDatatype: value.DataType,
|
|
attrStringValue: value.Val,
|
|
firstReportedUnixMilli: firstSeenUnixMilli,
|
|
lastReportedUnixMilli: lastSeenUnixMilli,
|
|
})
|
|
}
|
|
}
|
|
|
|
func (b *batch) addSample(sample *sample) {
|
|
b.samples = append(b.samples, sample)
|
|
}
|
|
|
|
func (b *batch) addTs(ts *ts) {
|
|
b.ts = append(b.ts, ts)
|
|
}
|
|
|
|
func (b *batch) addExpHist(expHist *exponentialHistogramSample) {
|
|
b.expHist = append(b.expHist, expHist)
|
|
}
|