$ make smoke
api → postgres job + outbox, 1 tx
relay → kafka 3 brokers, RF 3
worker ← kafka mark succeeded
lease ✳ redis fenced (next)
status IN PROGRESS
leasework ⇄
A distributed job scheduler in Go built around one promise: every job runs, and no job takes effect twice. Microservices on Postgres and a 3-broker Kafka cluster, with a transactional outbox so a crash between the DB write and the publish can't lose a job. Next up: Redis-backed fenced leases and Prometheus/Grafana autoscaling on consumer lag. Work in progress.
GO / KAFKA / POSTGRES / REDIS / PROMETHEUS