Crate gestura_core_nats 

NATS messaging helpers, server lifecycle, and health monitoring.

gestura-core-nats provides the optional NATS messaging integration used by Gestura for local or distributed event transport.

Main entry points

• connect_nats / connect_with_retry: connection helpers
• spawn_nats_server: embedded/local server process startup
• publish_json, subscribe, subscribe_wildcard: messaging primitives
• init_jetstream: JetStream KV bootstrap helper
• DispatchEvent: typed event envelope used by messaging flows
• NatsHealthMonitor: health and reconnection helper when the feature is enabled

Feature gates

The nats feature enables the actual async-nats implementation. When it is disabled, the crate exposes compatible stub/no-op behavior so dependent code can compile without pretending messaging is active.

Stable import paths

Most code should import through gestura_core::nats_mq::*.

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