Method CompileMetricsQueryRangeNonRaw

pkg/traceql/engine_metrics.go:937–979

(req *tempopb.QueryRangeRequest, mode AggregateMode, opts ...CompileOption)

}

func (e *Engine) CompileMetricsQueryRangeNonRaw(req *tempopb.QueryRangeRequest, mode AggregateMode, opts ...CompileOption) (*MetricsFrontendEvaluator, error) {
	if req.Exemplars > maxExemplars {
		level.Warn(log.Logger).Log("msg", "capping exemplars to safety limit", "requested", req.Exemplars, "cap", maxExemplars)
		req.Exemplars = maxExemplars
	}

	if req.Start <= 0 {
		return nil, fmt.Errorf("start required")
	}
	if req.End <= 0 {
		return nil, fmt.Errorf("end required")
	}
	if req.End <= req.Start {
		return nil, fmt.Errorf("end must be greater than start")
	}
	if req.Step <= 0 {
		return nil, fmt.Errorf("step required")
	}

	_, _, metricsPipeline, metricsSecondStage, _, err := Compile(req.Query, opts...)
	if err != nil {
		return nil, fmt.Errorf("compiling query: %w", err)
	}

	// for metrics queries, we need a metrics pipeline
	if metricsPipeline == nil {
		return nil, fmt.Errorf("not a metrics query")
	}

	metricsPipeline.init(req, mode)
	mfe := &MetricsFrontendEvaluator{
		metricsPipeline: metricsPipeline,
	}

	// only run metrics second stage if we have second stage and query mode = final,
	// as we are not sharding them now in lower layers.
	if metricsSecondStage != nil && mode == AggregateModeFinal {
		metricsSecondStage.init(req)
		mfe.metricsSecondStage = metricsSecondStage
	}

	return mfe, nil
}

// CompileMetricsQueryRange returns an evaluator that can be reused across multiple data sources.
func (e *Engine) CompileMetricsQueryRange(req *tempopb.QueryRangeRequest, opts ...CompileOption) (*MetricsEvaluator, error) {