Function cloneRequestforQueriers

modules/frontend/frontend.go:317–333

cloneRequestforQueriers returns a cloned pipeline.Request from the passed pipeline.Request ready for queriers. The caller is given an opportunity to modify the internal http.Request before it is returned using the modHTTP param. If modHTTP is nil, the internal http.Request is returned.

(parent pipeline.Request, tenant string, modHTTP func(*http.Request) (*http.Request, error))

// cloneRequestforQueriers returns a cloned pipeline.Request from the passed pipeline.Request ready for queriers. The caller is given an opportunity
// to modify the internal http.Request before it is returned using the modHTTP param. If modHTTP is nil, the internal http.Request is returned.
func cloneRequestforQueriers(parent pipeline.Request, tenant string, modHTTP func(*http.Request) (*http.Request, error)) (pipeline.Request, error) {
	req := parent.HTTPRequest()
	clonedHTTPReq := req.Clone(req.Context())

	// give the caller a chance to modify the internal http request
	if modHTTP != nil {
		var err error
		clonedHTTPReq, err = modHTTP(clonedHTTPReq)
		if err != nil {
			return nil, err
		}
	}

	prepareRequestForQueriers(clonedHTTPReq, tenant)

	return parent.CloneFromHTTPRequest(clonedHTTPReq), nil
}

// prepareRequestForQueriers modifies the request so they will be farmed correctly to the queriers
//   - adds the tenant header