Package ai.pipestream.connector.intake.v1

Class DocumentUploadServiceGrpc.DocumentUploadServiceBlockingV2Stub

java.lang.Object

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

io.grpc.stub.AbstractBlockingStub<DocumentUploadServiceGrpc.DocumentUploadServiceBlockingV2Stub>

ai.pipestream.connector.intake.v1.DocumentUploadServiceGrpc.DocumentUploadServiceBlockingV2Stub

Enclosing class:

DocumentUploadServiceGrpc

public static final class DocumentUploadServiceGrpc.DocumentUploadServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<DocumentUploadServiceGrpc.DocumentUploadServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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.DocumentUploadServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
GetUploadProgressResponse	getUploadProgress(GetUploadProgressRequest request)	Get upload progress - single snapshot
io.grpc.stub.BlockingClientCall<?,StreamUploadProgressResponse>	streamUploadProgress(StreamUploadProgressRequest request)	Stream upload progress - real-time updates
UploadChunkResponse	uploadChunk(UploadChunkRequest request)	Upload a single chunk - can be called in parallel for same file

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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.DocumentUploadServiceBlockingV2Stub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

uploadChunk

public UploadChunkResponse uploadChunk(UploadChunkRequest request)
                                throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

getUploadProgress

public GetUploadProgressResponse getUploadProgress(GetUploadProgressRequest request)
                                            throws io.grpc.StatusException

 Get upload progress - single snapshot
 

Throws:

io.grpc.StatusException

streamUploadProgress

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,StreamUploadProgressResponse> streamUploadProgress(StreamUploadProgressRequest request)

 Stream upload progress - real-time updates