Method TraceByIDHandler

modules/querier/http.go:35–82

TraceByIDHandler is a http.HandlerFunc to retrieve traces

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

// TraceByIDHandler is a http.HandlerFunc to retrieve traces
func (q *Querier) TraceByIDHandler(w http.ResponseWriter, r *http.Request) {
	// Enforce the query timeout while querying backends
	ctx, cancel := context.WithDeadline(r.Context(), time.Now().Add(q.cfg.TraceByID.QueryTimeout))
	defer cancel()

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

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

	// validate request
	blockStart, blockEnd, queryMode, timeStart, timeEnd, err := api.ValidateAndSanitizeRequest(r)
	if err != nil {
		http.Error(w, err.Error(), http.StatusBadRequest)
		return
	}
	span.AddEvent("validated request", oteltrace.WithAttributes(
		attribute.String("blockStart", blockStart),
		attribute.String("blockEnd", blockEnd),
		attribute.String("queryMode", queryMode),
		attribute.String("timeStart", fmt.Sprint(timeStart)),
		attribute.String("timeEnd", fmt.Sprint(timeEnd)),
		attribute.String("apiVersion", "v1"),
	))

	resp, err := q.FindTraceByID(ctx, &tempopb.TraceByIDRequest{
		TraceID:    byteID,
		BlockStart: blockStart,
		BlockEnd:   blockEnd,
		QueryMode:  queryMode,
	}, timeStart, timeEnd)
	if err != nil {
		handleError(w, err)
		return
	}

	// record not found here, but continue on so we can marshal metrics
	// to the body
	if resp.Trace == nil || len(resp.Trace.ResourceSpans) == 0 {
		w.WriteHeader(http.StatusNotFound)
	}

	writeFormattedContentForRequest(w, r, resp, span)
}

func (q *Querier) TraceByIDHandlerV2(w http.ResponseWriter, r *http.Request) {
	// Enforce the query timeout while querying backends