Package ai.pipeline.connector.intake.status

package ai.pipeline.connector.intake.status

Class	Description
IntakeOutcomeRecorder	Single place where an intake outcome is published.
UploadState	Intake outcome for a document, as recorded on an UploadReceipt and reported by the status lookup.
UploadStatusGrpcService	gRPC handler for GetUploadStatus — the parity of GET /uploads/status/{token}.
UploadStatusService	Projects the intake lifecycle event stream — DocumentAccepted, DocumentRejected, DocumentError — into the UploadReceipt read-model (upsert by doc_id) and resolves it for the status lookup.
UploadStatusService.StatusView	Client-safe status projection shared by the HTTP and gRPC status surfaces.