Package ai.pipestream.connector.intake.v1

Class DocumentUploadServiceClient

java.lang.Object

ai.pipestream.connector.intake.v1.DocumentUploadServiceClient

All Implemented Interfaces:

DocumentUploadService, io.quarkus.grpc.MutinyClient<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/document_upload.proto")
public class DocumentUploadServiceClient
extends Object
implements DocumentUploadService, io.quarkus.grpc.MutinyClient<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>

Constructor Summary

Constructors

Constructor	Description
DocumentUploadServiceClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub,MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub> stubConfigurator)

Method Summary

Modifier and Type	Method	Description
MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub	getStub()
io.smallrye.mutiny.Uni<GetUploadProgressResponse>	getUploadProgress(GetUploadProgressRequest request)	Get upload progress - single snapshot
DocumentUploadServiceClient	newInstanceWithStub(MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub stub)
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 java.lang.Object

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

Constructor Details

DocumentUploadServiceClient

public DocumentUploadServiceClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub,MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub> stubConfigurator)

Method Details

newInstanceWithStub

public DocumentUploadServiceClient newInstanceWithStub(MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>

getStub

public MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyDocumentUploadServiceGrpc.MutinyDocumentUploadServiceStub>

uploadChunk

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

Description copied from interface: DocumentUploadService

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

Specified by:

uploadChunk in interface DocumentUploadService

getUploadProgress

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

Description copied from interface: DocumentUploadService

  Get upload progress - single snapshot
 

Specified by:

getUploadProgress in interface DocumentUploadService

streamUploadProgress

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

Description copied from interface: DocumentUploadService

  Stream upload progress - real-time updates
 

Specified by:

streamUploadProgress in interface DocumentUploadService