Function processLayer1AndLayer2

pkg/traceql/engine_metrics_test.go:2981–3004

(req *tempopb.QueryRangeRequest, in ...[]Span)

}

func processLayer1AndLayer2(req *tempopb.QueryRangeRequest, in ...[]Span) (SeriesSet, error) {
	e := NewEngine()

	layer2, err := e.CompileMetricsQueryRangeNonRaw(req, AggregateModeSum)
	if err != nil {
		return nil, err
	}

	for _, spanSet := range in {
		layer1, err := e.CompileMetricsQueryRange(req)
		if err != nil {
			return nil, err
		}
		for _, s := range spanSet {
			layer1.metricsPipeline.observe(s)
		}
		res := layer1.Results()
		// Pass layer 1 to layer 2
		// These are partial counts over time by bucket
		layer2.metricsPipeline.observeSeries(res.ToProto(req))
	}

	return layer2.Results(), nil
}

func processLayer3(req *tempopb.QueryRangeRequest, results ...SeriesSet) (SeriesSet, int, error) {
	e := NewEngine()