Distributed Queue Architecture
System Operational | Idempotent Delivery Active
⏸ Pause
⚡ Simulate Redis Failure
↺ Reset
Pipeline Execution Layer (In-Memory & Workers)
Storage Layer (Postgres Single Source of Truth)
TRIGGER
ENQUEUE
PERSIST (FANOUT)
CLAIM
STATE CHANGE (ACK)
SCAN MISSING (CRON)
REPOPULATE QUEUE
CAMPAIGN INPUT
SCHEDULER
REDIS QUEUE
WORKER + LIMITER
RECONCILER
POSTGRESQL (DATABASE TABLES)
campaigns
emails (id, deterministic_job_id, status: SCHEDULED|SENT|SLID)
reconciliation_audit_logs
QUEUE FLUSHED / LOST
System Overview
Interactive Architecture
Hover or click on any pipeline node to inspect state transitions, deterministic job generation, rate-limiting constraints, and Postgres reconciliation guarantees. Click "Simulate Redis Failure" to test fault tolerance.