Package ai.pipestream.connector.intake.v1

Interface DocumentUploadServiceGrpc.AsyncService

All Known Implementing Classes:

DocumentUploadServiceGrpc.DocumentUploadServiceImplBase

Enclosing class:

DocumentUploadServiceGrpc

public static interface DocumentUploadServiceGrpc.AsyncService

 Chunked document upload service for large files.
 Provides simple parallel chunk uploads without streaming complexity.
 Supports progress tracking via unary and streaming RPCs.
 

Method Summary

Modifier and Type	Method	Description
default void	getUploadProgress(GetUploadProgressRequest request, io.grpc.stub.StreamObserver<GetUploadProgressResponse> responseObserver)	Get upload progress - single snapshot
default void	streamUploadProgress(StreamUploadProgressRequest request, io.grpc.stub.StreamObserver<StreamUploadProgressResponse> responseObserver)	Stream upload progress - real-time updates
default void	uploadChunk(UploadChunkRequest request, io.grpc.stub.StreamObserver<UploadChunkResponse> responseObserver)	Upload a single chunk - can be called in parallel for same file

Method Details

uploadChunk

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

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

getUploadProgress

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

 Get upload progress - single snapshot
 

streamUploadProgress

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

 Stream upload progress - real-time updates