Package ai.pipestream.connector.intake.v1

Class MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

java.lang.Object

ai.pipestream.connector.intake.v1.MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

DocumentUploadServiceBean

Enclosing class:

MutinyDocumentUploadServiceGrpc

public abstract static class MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase
extends Object
implements io.grpc.BindableService

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

Constructor Summary

Constructors

Constructor	Description
DocumentUploadServiceImplBase()

Method Summary

Modifier and Type	Method	Description
final io.grpc.ServerServiceDefinition	bindService()
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
MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase	withCompression(String compression)	Set whether the server will try to use a compressed response.

Methods inherited from class java.lang.Object

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

Constructor Details

DocumentUploadServiceImplBase

public DocumentUploadServiceImplBase()

Method Details

withCompression

public MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase withCompression(String compression)

Set whether the server will try to use a compressed response.

Parameters:

compression - the compression, e.g gzip

uploadChunk

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

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

getUploadProgress

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

  Get upload progress - single snapshot
 

streamUploadProgress

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

  Stream upload progress - real-time updates
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService