Class GrpcBlobUploadService

java.lang.Object

ai.pipeline.connector.intake.pipedoc.GrpcBlobUploadService

@ApplicationScoped
public class GrpcBlobUploadService
extends Object

Handles the unary UploadBlob RPC. Mirrors UnaryPipeDocUploadService: validation and downstream failures are normalized to a client-safe IntakeException (the response carries only the curated message, never a raw cause), and accept/reject is recorded + emitted via IntakeOutcomeRecorder.

Constructor Summary

Constructors

Constructor	Description
GrpcBlobUploadService()

Method Summary

Modifier and Type	Method	Description
void	uploadBlob(ai.pipestream.connector.intake.v1.UploadBlobRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadBlobResponse> responseObserver)

Methods inherited from class Object

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

Constructor Details

GrpcBlobUploadService

public GrpcBlobUploadService()

Method Details

uploadBlob

public void uploadBlob(ai.pipestream.connector.intake.v1.UploadBlobRequest request,
 io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadBlobResponse> responseObserver)