Method deletePayload

pkg/dequeuer/async_handler.go:162–169

(requestID string)

}

func (h *AsyncMessageHandler) deletePayload(requestID string) {
	key := async.PayloadPath(h.storagePath, requestID)
	err := h.aws.DeleteS3File(h.config.Bucket, key)
	if err != nil {
		h.log.Errorw("failed to delete user payload", "error", err)
		telemetry.Error(errors.Wrap(err, "failed to delete user payload"))
	}
}

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