Interface RepositoryUploadRestClient

@RegisterRestClient(configKey="repository-upload")
@Path("/internal/uploads/raw")
public interface RepositoryUploadRestClient

Declarative REST client for proxying raw uploads to repository-service.

Synchronous Response return (not Uni<Response>). The Mutiny-wrapped variant was eating backpressure events under concurrent load — 9 parallel s3 uploads would all log entry on connector-intake then silently lose their chains, leaving the body InputStream readers blocked with no thread parked on them and no error fired. Plain blocking REST client streams the body bytes directly through a worker thread; backpressure is HTTP/2 native and visible.

Method Summary

Modifier and Type	Method	Description
jakarta.ws.rs.core.Response	uploadRaw(InputStream body, String contentType, long contentLength, String accountId, String connectorId, String datasourceId, String docId, String driveName, String filename, String checksumSha256, String requestId, String crawlId, String forceSave)

Method Details

uploadRaw

@POST
@Consumes("*/*")
jakarta.ws.rs.core.Response uploadRaw(InputStream body,
 @HeaderParam("Content-Type")
 String contentType,
 @HeaderParam("Content-Length")
 long contentLength,
 @HeaderParam("x-account-id")
 String accountId,
 @HeaderParam("x-connector-id")
 String connectorId,
 @HeaderParam("x-datasource-id")
 String datasourceId,
 @HeaderParam("x-doc-id")
 String docId,
 @HeaderParam("x-drive-name")
 String driveName,
 @HeaderParam("x-filename")
 String filename,
 @HeaderParam("x-checksum-sha256")
 String checksumSha256,
 @HeaderParam("x-request-id")
 String requestId,
 @HeaderParam("x-crawl-id")
 String crawlId,
 @HeaderParam("x-force-save")
 String forceSave)