Struct NatsBus 

pub struct NatsBus { /* private fields */ }

NATS JetStream bus.

Implementations

impl NatsBus

pub fn provision(url: &str, manifest: &BridgeManifest) -> Result<Self, BusError>

Connect and provision streams per the manifest.

Trait Implementations

impl EventBus for NatsBus

fn find_event_by_uid( &self, topic: &str, key: &str, event_uid: &str, ) -> Result<Option<PublishAck>, BusError>

JetStream-aware UID lookup. The default trait implementation treats an empty fetch as proof of absence, but a NATS batch with a 500 ms expires can legitimately deliver zero messages before expiry on a loaded server even when matching messages exist — and a false “absent” makes crash-recovery maintenance re-produce an already-committed event (a duplicate in the audit stream once outside the JetStream dedup window). Use the consumer’s server-computed num_pending instead: zero pending on a freshly-created filtered consumer proves absence; an empty batch with pending remaining is a timing artifact and retries bounded, then fails the pass (callers retry later — the cold intent is durable).

fn set_control_key(&self, key: [u8; 32]) -> Result<(), BusError>

Configure the signer-derived key used for authenticated local controls.

fn publish( &self, topic: &str, key: &str, value: &Value, ) -> Result<PublishAck, BusError>

Publish value onto topic, partitioned by key. Returns the ack.

fn publish_idempotent( &self, topic: &str, key: &str, value: &Value, event_uid: &str, ) -> Result<PublishAck, BusError>

Publish a stable event UID. Backends with native or local deduplication override this method; the default preserves compatibility while the UID remains embedded in the event payload for downstream deduplication.

fn fetch( &self, topic: &str, partition: u32, offset: u64, max: usize, ) -> Result<Vec<StoredEvent>, BusError>

Read up to max events from topic/partition starting at offset (ordered replay).

fn partitions(&self, topic: &str) -> Result<u32, BusError>

Number of partitions configured for topic.

fn topics(&self) -> Vec<String>

Topics currently provisioned.

fn maintenance(&self, _now_ms: u64) -> Result<u64, BusError>

Run backend maintenance such as hot-retention expiry. Managed brokers may return zero when retention is enforced natively.