Method queryRangeRecent

modules/querier/querier_query_range.go:25–49

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

}

func (q *Querier) queryRangeRecent(ctx context.Context, req *tempopb.QueryRangeRequest) (*tempopb.QueryRangeResponse, error) {
	// correct max series limit logic should've been set by the query-frontend sharder
	c, err := traceql.QueryRangeCombinerFor(req, traceql.AggregateModeSum, int(req.MaxSeries))
	if err != nil {
		return nil, err
	}

	results, err := q.forLiveStoreMetricsRing(ctx, func(ctx context.Context, client tempopb.MetricsClient) (any, error) {
		return client.QueryRange(ctx, req)
	})
	if err != nil {
		_ = level.Error(log.Logger).Log("msg", "error querying live-stores in Querier.queryRangeRecent", "err", err)
		return nil, fmt.Errorf("error querying live-stores in Querier.queryRangeRecent: %w", err)
	}

	for _, result := range results {
		resp := result.(*tempopb.QueryRangeResponse)
		c.Combine(resp)
		if c.MaxSeriesReached() {
			break
		}
	}

	return c.Response(), nil
}

func (q *Querier) queryBlock(ctx context.Context, req *tempopb.QueryRangeRequest) (*tempopb.QueryRangeResponse, error) {
	tenantID, err := validation.ExtractValidTenantID(ctx)