Package ai.pipestream.connector.intake.v1

Interface DocumentUploadService

All Superinterfaces:

io.quarkus.grpc.MutinyService

All Known Implementing Classes:

DocumentUploadServiceClient

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/document_upload.proto")
public interface DocumentUploadService
extends io.quarkus.grpc.MutinyService

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<GetUploadProgressResponse>	getUploadProgress(GetUploadProgressRequest request)	Get upload progress - single snapshot
io.smallrye.mutiny.Multi<StreamUploadProgressResponse>	streamUploadProgress(StreamUploadProgressRequest request)	Stream upload progress - real-time updates
io.smallrye.mutiny.Uni<UploadChunkResponse>	uploadChunk(UploadChunkRequest request)	Upload a single chunk - can be called in parallel for same file

Method Details

uploadChunk

io.smallrye.mutiny.Uni<UploadChunkResponse> uploadChunk(UploadChunkRequest request)

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

getUploadProgress

io.smallrye.mutiny.Uni<GetUploadProgressResponse> getUploadProgress(GetUploadProgressRequest request)

  Get upload progress - single snapshot
 

streamUploadProgress

io.smallrye.mutiny.Multi<StreamUploadProgressResponse> streamUploadProgress(StreamUploadProgressRequest request)

  Stream upload progress - real-time updates