Method QueryRange

modules/livestore/instance_search.go:698–806

QueryRange returns metrics.

(ctx context.Context, req *tempopb.QueryRangeRequest)

// QueryRange returns metrics.
func (i *instance) QueryRange(ctx context.Context, req *tempopb.QueryRangeRequest) (*tempopb.QueryRangeResponse, error) {
	ctx, cancel := context.WithCancel(ctx)
	defer cancel()

	e := traceql.NewEngine()

	// Parse without optimizations to read hints; optimizations are applied by CompileMetricsQueryRange.
	expr, err := traceql.ParseNoOptimizations(req.Query)
	if err != nil {
		return nil, fmt.Errorf("compiling query: %w", err)
	}

	var compileOpts []traceql.CompileOption

	unsafe := i.overrides.UnsafeQueryHints(i.tenantID)
	if unsafe {
		compileOpts = append(compileOpts, traceql.WithUnsafeHints(true))
	}
	for _, name := range req.SkipASTTransformations {
		compileOpts = append(compileOpts, traceql.WithSkipOptimization(name))
	}

	if v, ok := expr.Hints.GetFloat(traceql.HintTimeOverlapCutoff, unsafe); ok && v >= 0 && v <= 1.0 {
		compileOpts = append(compileOpts, traceql.WithTimeOverlapCutoff(v))
	} else {
		compileOpts = append(compileOpts, traceql.WithTimeOverlapCutoff(i.Cfg.Metrics.TimeOverlapCutoff))
	}

	if p := i.overrides.MetricsSpanOnlyFetch(i.tenantID); p != nil {
		compileOpts = append(compileOpts, traceql.WithSpanOnlyFetch(*p))
	}

	// Compile the raw version of the query for head and wal blocks
	// These aren't cached and we put them all into the same evaluator
	// for efficiency.
	rawEval, err := e.CompileMetricsQueryRange(req, compileOpts...)
	if err != nil {
		return nil, err
	}

	// This is a summation version of the query for complete blocks
	// which can be cached. They are timeseries, so they need the job-level evaluator.
	jobEval, err := traceql.NewEngine().CompileMetricsQueryRangeNonRaw(req, traceql.AggregateModeSum, compileOpts...)
	if err != nil {
		return nil, err
	}

	cutoff := time.Now().Add(-i.Cfg.CompleteBlockTimeout).Add(-timeBuffer)
	if req.Start < uint64(cutoff.UnixNano()) {
		return nil, fmt.Errorf("time range must be within last %v", i.Cfg.CompleteBlockTimeout)
	}

	maxSeries := int(req.MaxSeries)
	maxSeriesReached := atomic.Bool{}
	maxSeriesReached.Store(false)

	search := func(ctx context.Context, _ *backend.BlockMeta, b block) error {
		if walBlock, ok := b.(common.WALBlock); ok {