Class RepositoryUploadClient

java.lang.Object

ai.pipestream.connector.intake.http.RepositoryUploadClient

@ApplicationScoped
public class RepositoryUploadClient
extends Object

Synchronous HTTP client for proxying raw uploads to repository-service.

Plain blocking REST call — caller (the @Blocking RawUploadResource handler) is on a worker thread, so blocking here is correct and intended. No Mutiny operators wrap the body forwarding, so the inbound HTTP request body InputStream and the outbound REST client body stream are coupled directly through the worker thread — backpressure is HTTP/2 native and visible.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	RepositoryUploadClient.RepositoryUploadResponse

Constructor Summary

Constructors

Constructor	Description
RepositoryUploadClient()

Method Summary

Modifier and Type	Method	Description
RepositoryUploadClient.RepositoryUploadResponse	uploadRaw(InputStream body, long contentLength, int bufferSize, Map<String,String> headers)	Forwards the raw upload to repository-service synchronously.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RepositoryUploadClient

public RepositoryUploadClient()

Method Details

uploadRaw

public RepositoryUploadClient.RepositoryUploadResponse uploadRaw(InputStream body,
 long contentLength,
 int bufferSize,
 Map<String,String> headers)

Forwards the raw upload to repository-service synchronously.

Parameters:

bufferSize - unused — kept in the signature for backwards compatibility with callers that previously needed to pass a chunk size. Quarkus REST client streams the body without per-chunk buffering.