Method submitRequest

pkg/dequeuer/async_handler.go:171–211

(payload io.Reader, headers http.Header, requestID string)

}

func (h *AsyncMessageHandler) submitRequest(payload io.Reader, headers http.Header, requestID string) (interface{}, error) {
	req, err := http.NewRequest(http.MethodPost, h.config.TargetURL, payload)
	if err != nil {
		return nil, errors.WithStack(err)
	}

	req.Header = headers
	req.Header.Set(CortexRequestIDHeader, requestID)

	startTime := time.Now()
	response, err := h.httpClient.Do(req)
	if err != nil {
		return nil, ErrorUserContainerNotReachable(err)
	}

	defer func() {
		_ = response.Body.Close()
	}()

	h.eventHandler.HandleEvent(
		RequestEvent{
			StatusCode: response.StatusCode,
			Duration:   time.Since(startTime),
		},
	)

	if response.StatusCode != http.StatusOK {
		return nil, ErrorUserContainerResponseStatusCode(response.StatusCode)
	}

	if !strings.HasPrefix(response.Header.Get("Content-Type"), "application/json") {
		return nil, ErrorUserContainerResponseMissingJSONHeader()
	}

	var result interface{}
	if err = json.NewDecoder(response.Body).Decode(&result); err != nil {
		return nil, ErrorUserContainerResponseNotJSONDecodable()
	}

	return result, nil
}

func (h *AsyncMessageHandler) uploadResult(requestID string, result interface{}) error {
	key := async.ResultPath(h.storagePath, requestID)