SearchRecent implements tempopb.Querier
(ctx context.Context, req *tempopb.SearchRequest)
| 845 | |
| 846 | // SearchRecent implements tempopb.Querier |
| 847 | func (s *LiveStore) SearchRecent(ctx context.Context, req *tempopb.SearchRequest) (*tempopb.SearchResponse, error) { |
| 848 | return withInstance(ctx, s, func(inst *instance) (*tempopb.SearchResponse, error) { |
| 849 | if s.isLagged(int64(req.End) * 1e9) { // convert seconds to nanoseconds |
| 850 | metricLaggedRequests.WithLabelValues("/tempopb.Querier/SearchRecent").Inc() |
| 851 | if s.cfg.FailOnHighLag { |
| 852 | return nil, errLagged |
| 853 | } |
| 854 | } |
| 855 | return inst.Search(ctx, req) |
| 856 | }) |
| 857 | } |
| 858 | |
| 859 | // SearchBlock implements tempopb.Querier |
| 860 | func (s *LiveStore) SearchBlock(_ context.Context, _ *tempopb.SearchBlockRequest) (*tempopb.SearchResponse, error) { |
nothing calls this directly
no test coverage detected