Method queryBlock

modules/querier/querier_query_range.go:51–159

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

}

func (q *Querier) queryBlock(ctx context.Context, req *tempopb.QueryRangeRequest) (*tempopb.QueryRangeResponse, error) {
	tenantID, err := validation.ExtractValidTenantID(ctx)
	if err != nil {
		return nil, fmt.Errorf("error extracting org id in Querier.queryBlock: %w", err)
	}

	blockID, err := backend.ParseUUID(req.BlockID)
	if err != nil {
		return nil, err
	}

	dc, err := backend.DedicatedColumnsFromTempopb(req.DedicatedColumns)
	if err != nil {
		return nil, err
	}

	meta := &backend.BlockMeta{
		Version:          req.Version,
		TenantID:         tenantID,
		StartTime:        time.Unix(0, int64(req.Start)),
		EndTime:          time.Unix(0, int64(req.End)),
		BlockID:          blockID,
		Size_:            req.Size_,
		FooterSize:       req.FooterSize,
		DedicatedColumns: dc,
	}

	opts := common.DefaultSearchOptions()
	opts.StartPage = int(req.StartPage)
	opts.TotalPages = int(req.PagesToSearch)

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

	var compileOpts []traceql.CompileOption

	unsafe := q.limits.UnsafeQueryHints(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 {
		// Use valid hint from query.
		compileOpts = append(compileOpts, traceql.WithTimeOverlapCutoff(v))
	} else {
		// Use default.
		compileOpts = append(compileOpts, traceql.WithTimeOverlapCutoff(q.cfg.Metrics.TimeOverlapCutoff))
	}

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