ReplayForge

ReplayForge is a crash-recovery platform for asynchronous workflows.

What it does

• Accepts workflow events through an API
• Buffers them in Redis Streams
• Processes them with a Go worker pool
• Persists idempotent state in PostgreSQL
• Recovers stalled work with a janitor loop
• Exposes the system through an API and dashboard

Architecture

flowchart LR
    A[API client] --> B[FastAPI control plane]
    B --> C[(Redis Streams)]
    C --> D[Go worker pool]
    D --> E[(PostgreSQL)]
    D --> C
    F[Recovery janitor] --> C
    G[Frontend dashboard] --> B
    B --> E

Loading

Quick start

docker compose down -v --remove-orphans
docker compose up --build -d
docker compose ps
./scripts/check_state.sh
make chaos

Design notes

• The recovery model is at-least-once with idempotent convergence.
• The janitor reclaims stale pending entries.
• The repo includes benchmark and diagnostic tooling for failure scenarios.

Portfolio Proof

• Architecture and evaluation: docs/PORTFOLIO_PROOF.md
• Demo and local mode: docker compose up --build -d, ./scripts/check_state.sh, make chaos
• Benchmark runner: python scripts/run_chaos_benchmark.py --events 10000 --workers 4 (use --dry-run or --pending to avoid contacting the API)
• Test commands: backend pytest, worker go test ./..., frontend build if needed
• Reliability proof: chaos and runbook docs under docs/