Method QueryRangeHandler

modules/querier/http.go:328–382

(w http.ResponseWriter, r *http.Request)

}

func (q *Querier) QueryRangeHandler(w http.ResponseWriter, r *http.Request) {
	var (
		err  error
		resp *tempopb.QueryRangeResponse
	)

	// Enforce the query timeout while querying backends
	ctx, cancel := context.WithDeadline(r.Context(), time.Now().Add(q.cfg.Search.QueryTimeout))
	defer cancel()

	ctx, span := tracer.Start(ctx, "Querier.QueryRangeHandler")
	defer span.End()

	// Special error handling to update the span.
	defer func() {
		if errors.Is(err, context.Canceled) {
			// todo: context is also canceled when we hit the query timeout. research what the behavior is
			// ignore this error. we regularly cancel context once queries are complete
			span.RecordError(err)
			return
		}

		if ctx.Err() != nil {
			span.RecordError(ctx.Err())
			return
		}

		if err != nil {
			span.RecordError(err)
		}
	}()

	req, err := api.ParseQueryRangeRequest(r)
	if err != nil {
		http.Error(w, err.Error(), http.StatusBadRequest)
		return
	}

	span.SetAttributes(attribute.String("query", req.Query))
	span.SetAttributes(attribute.Int64("step", time.Duration(req.Step).Nanoseconds()))
	span.SetAttributes(attribute.Int64("interval", time.Unix(0, int64(req.End)).Sub(time.Unix(0, int64(req.Start))).Nanoseconds()))

	resp, err = q.QueryRange(ctx, req)
	if err != nil {
		handleError(w, err)
		return
	}

	if resp != nil && resp.Metrics != nil {
		span.SetAttributes(attribute.Int64("inspectedBytes", int64(resp.Metrics.InspectedBytes)))
		span.SetAttributes(attribute.Int64("inspectedSpans", int64(resp.Metrics.InspectedSpans)))
	}

	writeFormattedContentForRequest(w, r, resp, span)
}

func handleError(w http.ResponseWriter, err error) {
	if err == nil {