Decoupled Microservices Pipeline
Real-Time Event Processing Engine
Asynchronous message passing via NATS queue groups with persistent PostgreSQL state tracking and HTMX SSE live browser updates.
Gateway
HTTP + SSE Port :8080NATS Bus
Queue Group jobs.createdWorker
Image & PDF ConsumerPostgreSQL
State Machine Row LockingTotal Ingested
0
Completed
0
In Flight
0
Storage Health
TTL Active
Ingestion Gateway • HTTP 202 Accepted Async Ingestion
Submit Media or Document Task
Upload a file for asynchronous background processing, thumbnailing, and metadata extraction.
Live Tasks Stream
0 Total SSE Connected⚡
No active media tasks
Upload an image or document above or click "Quick Demo" to observe real-time background processing.