Package ai.pipestream.connector.intake.v1

Class DocumentUploadServiceGrpc.DocumentUploadServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<DocumentUploadServiceGrpc.DocumentUploadServiceStub>

io.grpc.stub.AbstractAsyncStub<DocumentUploadServiceGrpc.DocumentUploadServiceStub>

ai.pipestream.connector.intake.v1.DocumentUploadServiceGrpc.DocumentUploadServiceStub

Enclosing class:

DocumentUploadServiceGrpc

public static final class DocumentUploadServiceGrpc.DocumentUploadServiceStub
extends io.grpc.stub.AbstractAsyncStub<DocumentUploadServiceGrpc.DocumentUploadServiceStub>

A stub to allow clients to do asynchronous 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 Type	Method	Description
protected DocumentUploadServiceGrpc.DocumentUploadServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	getUploadProgress(GetUploadProgressRequest request, io.grpc.stub.StreamObserver<GetUploadProgressResponse> responseObserver)	Get upload progress - single snapshot
void	streamUploadProgress(StreamUploadProgressRequest request, io.grpc.stub.StreamObserver<StreamUploadProgressResponse> responseObserver)	Stream upload progress - real-time updates
void	uploadChunk(UploadChunkRequest request, io.grpc.stub.StreamObserver<UploadChunkResponse> responseObserver)	Upload a single chunk - can be called in parallel for same file

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Details

build

protected DocumentUploadServiceGrpc.DocumentUploadServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<DocumentUploadServiceGrpc.DocumentUploadServiceStub>

uploadChunk

public void uploadChunk(UploadChunkRequest request,
 io.grpc.stub.StreamObserver<UploadChunkResponse> responseObserver)

 Upload a single chunk - can be called in parallel for same file
 

getUploadProgress

public void getUploadProgress(GetUploadProgressRequest request,
 io.grpc.stub.StreamObserver<GetUploadProgressResponse> responseObserver)

 Get upload progress - single snapshot
 

streamUploadProgress

public void streamUploadProgress(StreamUploadProgressRequest request,
 io.grpc.stub.StreamObserver<StreamUploadProgressResponse> responseObserver)

 Stream upload progress - real-time updates