Crate eventbus_nats 

Re-exports

pub use builder::EventBusBuilder;

pub use bus::EventBus;

pub use bus::SubscriptionHandle;

pub use bus_nats as nats;

pub use bus_core as core;

Modules

builder

bus

prelude

Structs

ConnectOptions

Connect options. Used to connect with NATS when custom config is needed.

NatsClient

Thin wrapper over async_nats::Client + jetstream::Context.

NatsKvIdempotencyConfig

Configuration for NatsKvIdempotencyStore.

NatsPublisher

NATS JetStream implementation of Publisher. Attaches Nats-Msg-Id header for server-side deduplication.

StreamConfig

Configuration for the JetStream stream. Defaults are production-safe: R3 replication, 5-minute dedup window.

SubscribeOptions

Options for subscribing to events from a JetStream stream.