Method QueryRange

modules/livestore/live_store.go:893–903

QueryRange implements tempopb.MetricsServer

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

// QueryRange implements tempopb.MetricsServer
func (s *LiveStore) QueryRange(ctx context.Context, req *tempopb.QueryRangeRequest) (*tempopb.QueryRangeResponse, error) {
	return withInstance(ctx, s, func(inst *instance) (*tempopb.QueryRangeResponse, error) {
		if s.isLagged(int64(req.End)) { // end param is already nanos, no need to convert
			metricLaggedRequests.WithLabelValues("/tempopb.Metrics/QueryRange").Inc()
			if s.cfg.FailOnHighLag {
				return nil, errLagged
			}
		}
		return inst.QueryRange(ctx, req)
	})
}

var errLagged = errors.New("cannot guarantee complete results")