Package ai.pipestream.connector.intake.v1

Class DocumentUploadServiceBean

java.lang.Object

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

ai.pipestream.connector.intake.v1.DocumentUploadServiceBean

All Implemented Interfaces:

io.grpc.BindableService, io.quarkus.grpc.MutinyBean

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/document_upload.proto")
public class DocumentUploadServiceBean
extends MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase
implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean

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

Methods inherited from class ai.pipestream.connector.intake.v1.MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

bindService, withCompression

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.grpc.BindableService

bindService

Method Details

uploadChunk

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

Description copied from class: MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

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

Overrides:

uploadChunk in class MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

getUploadProgress

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

Description copied from class: MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

  Get upload progress - single snapshot
 

Overrides:

getUploadProgress in class MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

streamUploadProgress

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

Description copied from class: MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase

  Stream upload progress - real-time updates
 

Overrides:

streamUploadProgress in class MutinyDocumentUploadServiceGrpc.DocumentUploadServiceImplBase