Class DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub
java.lang.Object
io.grpc.stub.AbstractStub<DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub>
io.grpc.stub.AbstractFutureStub<DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub>
ai.pipestream.connector.intake.v1.DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub
- Enclosing class:
DocumentUploadServiceGrpc
public static final class DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service DocumentUploadService.
Chunked document upload service for large files. Provides simple parallel chunk uploads without streaming complexity. Supports progress tracking via unary and streaming RPCs.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>> -
Method Summary
Modifier and TypeMethodDescriptionbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) com.google.common.util.concurrent.ListenableFuture<GetUploadProgressResponse> Get upload progress - single snapshotcom.google.common.util.concurrent.ListenableFuture<UploadChunkResponse> uploadChunk(UploadChunkRequest request) Upload a single chunk - can be called in parallel for same fileMethods inherited from class io.grpc.stub.AbstractFutureStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
buildin classio.grpc.stub.AbstractStub<DocumentUploadServiceGrpc.DocumentUploadServiceFutureStub>
-
uploadChunk
public com.google.common.util.concurrent.ListenableFuture<UploadChunkResponse> uploadChunk(UploadChunkRequest request) Upload a single chunk - can be called in parallel for same file
-
getUploadProgress
public com.google.common.util.concurrent.ListenableFuture<GetUploadProgressResponse> getUploadProgress(GetUploadProgressRequest request) Get upload progress - single snapshot
-