Module nats 

NATS core and JetStream source and sink connectors. NATS source and sink — core (non-durable, at-most-once) or jetstream (default; replayable; at-least-once, or exactly-once with Nats-Msg-Id dedup).

Re-exports

pub use metrics::NatsSinkMetrics;

pub use metrics::NatsSourceMetrics;

pub use sink::NatsSink;

pub use source::NatsSource;

Modules

config

NATS source and sink configuration.

metrics

NATS connector metrics. No per-subject labels — subjects are wildcard-addressable and unbounded-cardinality.

sink

NATS sink. Core publishes are fire-and-forget; JetStream collects PublishAckFutures and drains them in flush / pre_commit. Exactly-once uses server-side Nats-Msg-Id dedup (see LDB-5056).

source

NATS source: JetStream pull consumer with ack-on-commit, or core subscribe (at-most-once). A background task forwards messages through an mpsc channel; JS message handles are retained until notify_epoch_committed fires, then acked in bulk.

Functions

register_nats_sink

Registers the NATS sink connector.

register_nats_source

Registers the NATS source connector.