NATS CommandBus transport (distributed single writer) #9

New issue

Open

opened 2026-02-19 21:28:02 +00:00 by ash · 0 comments

ash commented

2026-02-19 21:28:02 +00:00

Owner

What

Add NATS transport to CommandBus for distributed deployments.

Design

Same CommandBus interface, NATS queue groups as transport
Client sends command to NATS queue → single processor per stream
SendAndWait via reply subjects or result stream
Graceful failover: if processor dies, another picks up

Reference

Myrra command package at /tmp/yoyopass/pkg/myrra/command/ for patterns.
Make it better: generic commands, no baked-in OTel.

Tests

Integration test with embedded NATS
Failover behavior
Ordering guarantees
Benchmark vs in-process bus overhead

## What Add NATS transport to CommandBus for distributed deployments. ## Design - Same CommandBus interface, NATS queue groups as transport - Client sends command to NATS queue → single processor per stream - SendAndWait via reply subjects or result stream - Graceful failover: if processor dies, another picks up ## Reference Myrra command package at /tmp/yoyopass/pkg/myrra/command/ for patterns. Make it better: generic commands, no baked-in OTel. ## Tests - Integration test with embedded NATS - Failover behavior - Ordering guarantees - Benchmark vs in-process bus overhead