Class UploadStatusGrpcService

java.lang.Object

ai.pipeline.connector.intake.status.UploadStatusGrpcService

@ApplicationScoped
public class UploadStatusGrpcService
extends Object

gRPC handler for GetUploadStatus — the parity of GET /uploads/status/{token}. The signed token is the capability; a tampered/invalid/missing token maps to INVALID_ARGUMENT (the gRPC analogue of the HTTP 400) with a curated message, never internal detail. A valid token whose document is not yet projected reports PENDING.

Constructor Summary

Constructors

Constructor	Description
UploadStatusGrpcService()

Method Summary

Modifier and Type	Method	Description
void	getUploadStatus(ai.pipestream.connector.intake.v1.GetUploadStatusRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.GetUploadStatusResponse> responseObserver)

Methods inherited from class Object

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

Constructor Details

UploadStatusGrpcService

public UploadStatusGrpcService()

Method Details

getUploadStatus

public void getUploadStatus(ai.pipestream.connector.intake.v1.GetUploadStatusRequest request,
 io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.GetUploadStatusResponse> responseObserver)