Module nats_mq 

NATS messaging primitives re-exported from gestura-core-nats.

Modules

subjects

Common NATS subjects used across the app

Structs

NatsHealthMonitor

NATS connection health monitor

Enums

DispatchEvent

Dispatcher hint for event routing

Functions

connect_nats

Connect to NATS server

connect_with_retry

Attempt to connect to NATS with retries

init_jetstream

Initialize JetStream context and create KV bucket if missing

publish_json

Publish a JSON payload to a subject

spawn_nats_server

Spawn an embedded NATS server with JetStream enabled

subscribe

Subscribe to a subject with message handler

subscribe_wildcard

Subscribe to a wildcard subject

Type Aliases

Connection

NATS connection type