(ctx context.Context, req *tempopb.SearchRequest)
| 354 | } |
| 355 | |
| 356 | func (q *Querier) SearchRecent(ctx context.Context, req *tempopb.SearchRequest) (*tempopb.SearchResponse, error) { |
| 357 | if _, err := validation.ExtractValidTenantID(ctx); err != nil { |
| 358 | return nil, fmt.Errorf("error extracting org id in Querier.SearchRecent: %w", err) |
| 359 | } |
| 360 | |
| 361 | results, err := q.forLiveStoreRing(ctx, func(ctx context.Context, client tempopb.QuerierClient) (any, error) { |
| 362 | return client.SearchRecent(ctx, req) |
| 363 | }) |
| 364 | if err != nil { |
| 365 | return nil, fmt.Errorf("error querying live-stores in Querier.SearchRecent: %w", err) |
| 366 | } |
| 367 | |
| 368 | return q.postProcessIngesterSearchResults(req, results), nil |
| 369 | } |
| 370 | |
| 371 | func (q *Querier) SearchTagsBlocks(ctx context.Context, req *tempopb.SearchTagsBlockRequest) (*tempopb.SearchTagsResponse, error) { |
| 372 | v2Response, err := q.internalTagsSearchBlockV2(ctx, req) |
no test coverage detected