Package ai.pipestream.connector.intake.v1

Class MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>

ai.pipestream.connector.intake.v1.MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub

All Implemented Interfaces:

io.quarkus.grpc.MutinyStub

Enclosing class:

MutinyDocumentUploadServiceGrpc

public static final class MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub
extends io.grpc.stub.AbstractStub<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>
implements io.quarkus.grpc.MutinyStub

  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 MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
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 io.grpc.stub.AbstractStub

getCallOptions, getChannel, newStub, newStub, 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 MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>

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