Package ai.pipestream.connector.intake.v1

Class DocumentUploadServiceGrpc.DocumentUploadServiceBlockingStub

java.lang.Object

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

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

ai.pipestream.connector.intake.v1.DocumentUploadServiceGrpc.DocumentUploadServiceBlockingStub

Enclosing class:

DocumentUploadServiceGrpc

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

A stub to allow clients to do limited 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.DocumentUploadServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
GetUploadProgressResponse	getUploadProgress(GetUploadProgressRequest request)	Get upload progress - single snapshot
Iterator<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.DocumentUploadServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

uploadChunk

public UploadChunkResponse uploadChunk(UploadChunkRequest request)

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

getUploadProgress

public GetUploadProgressResponse getUploadProgress(GetUploadProgressRequest request)

 Get upload progress - single snapshot
 

streamUploadProgress

public Iterator<StreamUploadProgressResponse> streamUploadProgress(StreamUploadProgressRequest request)

 Stream upload progress - real-time updates