Method Do

pkg/querier/tripperware/roundtrip.go:268–292

Do implements Handler.

(ctx context.Context, r Request)

// Do implements Handler.
func (q roundTripper) Do(ctx context.Context, r Request) (Response, error) {
	request, err := q.codec.EncodeRequest(ctx, r)
	if err != nil {
		return nil, err
	}

	if requestMetadataMap := requestmeta.MapFromContext(ctx); requestMetadataMap != nil {
		requestmeta.InjectMetadataIntoHTTPRequestHeaders(requestMetadataMap, request)
	}

	if err := user.InjectOrgIDIntoHTTPRequest(ctx, request); err != nil {
		return nil, httpgrpc.Errorf(http.StatusBadRequest, "%s", err.Error())
	}

	response, err := q.next.RoundTrip(request)
	if err != nil {
		return nil, err
	}
	defer func() {
		io.Copy(io.Discard, io.LimitReader(response.Body, 1024))
		_ = response.Body.Close()
	}()

	return q.codec.DecodeResponse(ctx, response, r)
}

func GetSource(r *http.Request) string {
	// check it for backwards compatibility