Method HTTPFinal

modules/frontend/combiner/trace_by_id.go:108–166

()

}

func (c *TraceByIDCombiner) HTTPFinal() (*http.Response, error) {
	c.mu.Lock()
	defer c.mu.Unlock()

	statusCode := c.code
	traceResult, _ := c.c.Result()

	if statusCode != http.StatusOK {
		return &http.Response{
			StatusCode: statusCode,
			Body:       io.NopCloser(strings.NewReader(c.statusMessage)),
			Header:     http.Header{},
		}, nil
	}

	// if we have no trace result just substitute and return an empty trace
	if traceResult == nil {
		traceResult = &tempopb.Trace{}
	}

	// dedupe duplicate span ids
	deduper := newDeduper()
	traceResult = deduper.dedupe(traceResult)
	if c.traceRedactor != nil {
		err := c.traceRedactor.RedactTraceAttributes(traceResult)
		if err != nil {
			if errors.Is(err, ErrTraceHidden) {
				return &http.Response{
					StatusCode: http.StatusNotFound,
					Body:       http.NoBody,
					Header:     http.Header{},
				}, nil
			}
			return &http.Response{}, fmt.Errorf("trace redactor error: %w", err)
		}
	}

	// marshal in the requested format
	var buff []byte
	var err error

	if c.contentType == api.MarshallingFormatProtobuf {
		buff, err = proto.Marshal(traceResult)
	} else {
		buff, err = tempopb.MarshalToJSONV1(traceResult)
	}
	if err != nil {
		return &http.Response{}, fmt.Errorf("error marshalling response: %w content type: %s", err, c.contentType)
	}

	return &http.Response{
		StatusCode: http.StatusOK,
		Header: http.Header{
			api.HeaderContentType: {string(c.contentType)},
		},
		Body:          io.NopCloser(bytes.NewReader(buff)),
		ContentLength: int64(len(buff)),
	}, nil