From ad367c17bf2897cb8d69cda3c30abc955abd4dde Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Mon, 15 Jul 2024 21:58:56 +0200 Subject: [PATCH] lib/streamaggr/streamaggr.go: typo fix after 5e29ef5ed5f470751a4339ba2234c26ea81c5b88: IgnoredNaNSamples -> ignoredNaNSamples --- lib/streamaggr/streamaggr.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/streamaggr/streamaggr.go b/lib/streamaggr/streamaggr.go index 8e6068b7f..c8571b9d7 100644 --- a/lib/streamaggr/streamaggr.go +++ b/lib/streamaggr/streamaggr.go @@ -405,7 +405,7 @@ type aggregator struct { flushTimeouts *metrics.Counter dedupFlushTimeouts *metrics.Counter ignoredOldSamples *metrics.Counter - IgnoredNaNSamples *metrics.Counter + ignoredNaNSamples *metrics.Counter matchedSamples *metrics.Counter } @@ -606,7 +606,7 @@ func newAggregator(cfg *Config, path string, pushFunc PushFunc, ms *metrics.Set, matchedSamples: ms.NewCounter(fmt.Sprintf(`vm_streamaggr_matched_samples_total{%s}`, metricLabels)), flushTimeouts: ms.NewCounter(fmt.Sprintf(`vm_streamaggr_flush_timeouts_total{%s}`, metricLabels)), dedupFlushTimeouts: ms.NewCounter(fmt.Sprintf(`vm_streamaggr_dedup_flush_timeouts_total{%s}`, metricLabels)), - IgnoredNaNSamples: ms.NewCounter(fmt.Sprintf(`vm_streamaggr_ignored_samples_total{reason="nan",%s}`, metricLabels)), + ignoredNaNSamples: ms.NewCounter(fmt.Sprintf(`vm_streamaggr_ignored_samples_total{reason="nan",%s}`, metricLabels)), ignoredOldSamples: ms.NewCounter(fmt.Sprintf(`vm_streamaggr_ignored_samples_total{reason="too_old",%s}`, metricLabels)), } @@ -934,7 +934,7 @@ func (a *aggregator) Push(tss []prompbmarshal.TimeSeries, matchIdxs []byte) { key := bytesutil.ToUnsafeString(buf[bufLen:]) for _, s := range ts.Samples { if math.IsNaN(s.Value) { - a.IgnoredNaNSamples.Inc() + a.ignoredNaNSamples.Inc() // Skip NaN values continue }