Method getSeries

pkg/traceql/engine_metrics_average.go:568–596

getSeries gets the series for the current span. It will reuse the last series if possible.

(span Span)

// getSeries gets the series for the current span.
// It will reuse the last series if possible.
func (g *avgOverTimeSpanAggregator[F, S]) getSeries(span Span) avgOverTimeSeries[S] {
	// Get Grouping values
	for i, lookups := range g.byLookups {
		val := lookup(lookups, span)
		g.buf.vals[i] = val
		g.buf.fast[i] = val.MapKey()
	}

	// Fast path
	if g.lastBuf.fast == g.buf.fast && g.lastSeries.initialized {
		return g.lastSeries
	}

	s, ok := g.series[g.buf.fast]
	if !ok {
		intervals := g.intervalMapper.IntervalCount()
		s = avgOverTimeSeries[S]{
			vals:            g.buf.vals,
			average:         newAverageSeries(intervals, g.exemplars, nil),
			exemplarBuckets: newExemplarBucketSet(g.exemplars, g.start, g.end, g.step, g.instant),
			initialized:     true,
		}
		g.series[g.buf.fast] = s
	}

	g.lastBuf = g.buf
	g.lastSeries = s
	return s
}