Package ai.pipestream.connector.intake.event

package ai.pipestream.connector.intake.event

Classes

Class	Description
IntakeEventKeyExtractors	UUID key extractors for the intake event types, auto-discovered by the quarkus-apicurio-registry-protobuf extension and used to key each record for Kafka partitioning + dedup.
IntakeEventKeyExtractors.DocumentAcceptedExtractor
IntakeEventKeyExtractors.DocumentErrorExtractor
IntakeEventKeyExtractors.DocumentRejectedExtractor
IntakeEventProducer	Publishes intake lifecycle events to Kafka via the platform's quarkus-apicurio-registry-protobuf extension: inject a typed ProtobufEmitter per channel and call send(event) — the extension handles protobuf serialization, the deterministic UUID key (via IntakeEventKeyExtractors), Apicurio schema registration, and topic wiring.
IntakeEvents	Builds the intake_events protos from upload context and maps the service's IntakeErrorCode taxonomy onto the proto's RejectionReason.
IntakeReceiptProjector	Projects the intake lifecycle event streams — accepted, rejected, error — into the upload-receipt read-model that backs the status lookup.