Scheduler-service - 7001

• POST /internal/schedule/run
• GET /internal/schedule/health

Talks to :

POSTGRES → reads rpcs

KAFKA → produces → [rpc.jobs](<http://rpc.jobs>)

Worker - 7002

Consume jobs , Execute RPC requests , Emit results

• GET internal/worker/health
• POST /internal/worker/heartbeat

Talks to :

Kafka (consume rpc.jobs)
Kafka (produce rpc.results)
Redis → heartbeat cache

Ingestion API - 7003

Consume results , Insert into DB

• GET /internal/ingestion/health
• POST /internal/ingestion/replay

Talks to :

Kafka (rpc.results)
PostgreSQL → writes state

Incident Engine - 7004

• GET /internal/incidents/health
• GET /internal/incidents/active