Crate ruststream_nats 

NATS / JetStream broker implementation for RustStream.

Structs

CoreMessage

Wrapper around an async_nats::Message from a core (non-JetStream) subscription.

JetStreamMessage

Wrapper around an async_nats::jetstream::Message with ack semantics.

NatsBroker

A NATS broker handle backed by an async_nats::Client.

NatsPublisher

NATS publisher built on top of async_nats::Client. Cheap to clone.

NatsSubscriber

A NATS subscription.

SubscribeOptions

Builder describing one subscription against crate::NatsBroker (or its test counterpart).

Enums

DeliverPolicy

DeliverPolicy determines how the consumer should select the first message to deliver.

NatsError

Errors surfaced by the NATS broker implementation.

NatsMessage

A NATS delivery. Two flavours: core NATS (no ack) and JetStream (real ack/nack/redelivery).

Constants

PARTITION_KEY_HEADER

The well-known header key for per-message routing / partitioning.