[dependabot]

Bumps async-nats from 0.50.0 to 0.51.0.

Release notes

Sourced from async-nats's releases.

Release async-nats/v0.51.0

Overview

This release adds pinned client support for pull consumers and fixes a number of panics and hangs across JetStream, KV, Object Store and Service APIs. JetStream API requests are now bounded by the JetStream context timeout when it is set.

It is a minor release because it adds variants to error kind enums, adds public fields to consumer types and raises the MSRV to 1.89.

Added

• Add pinned client support for pull consumers by @​Nielswps in nats-io/nats.rs#1652
• Add priority_timeout, unpin_consumer and consumer priority group state by @​Nielswps in nats-io/nats.rs#1653
• Add docs.nats.io examples by @​Jarema in nats-io/nats.rs#1610

Fixed

• Fix FetchBuilder::priority overwriting batch size instead of setting priority by @​Jarema in nats-io/nats.rs#1620
• Accept the 11-token v2 JetStream ack subject by @​Jarema in nats-io/nats.rs#1624
• Fix object store reads panicking on a JetStream timeout by @​macrauder in nats-io/nats.rs#1621
• Avoid panic in Subscriber::drop when dropped outside a runtime by @​lives-hoth in nats-io/nats.rs#1608
• Fix spurious MissingHeartbeat while consumer messages are buffered by @​Jarema in nats-io/nats.rs#1627
• Stop pull consumers from hot-looping on 409 Exceeded MaxRequest* by @​Jarema in nats-io/nats.rs#1631
• Fix KV history and keys hanging when no entry arrives by @​Jarema in nats-io/nats.rs#1635
• Bound JetStream API requests by the context timeout when it is set by @​Jarema in nats-io/nats.rs#1636
• Fix service verb handler panicking on requests without a reply subject by @​cacoco in nats-io/nats.rs#1640
• Fix Service::stop leaving the service registered when no endpoint listens by @​cacoco in nats-io/nats.rs#1658
• Fix service error Display swapping code and status by @​SashaMIT in nats-io/nats.rs#1645
• Redact secrets in ConnectInfo Debug output by @​stasimus in nats-io/nats.rs#1616

Changed

• Use direct get in ObjectStore::info() when the stream allows it by @​sheapwilliams in nats-io/nats.rs#1632
• Improve ordered consumers naming by @​Jarema in nats-io/nats.rs#1626
• Clean up websocket dependencies and update tokio-websockets to 0.13.3 by @​Jarema in nats-io/nats.rs#1656
• Tidy the object store read error path by @​Jarema in nats-io/nats.rs#1625

Breaking changes

• MSRV is now Rust 1.89, required by tokio-websockets 0.13 (#1656).
• The minimum aws-lc-rs version is now 1.18, as older releases allow an aws-lc-fips-sys that does not build with CMake 4. Under fips this moves the bundled AWS-LC-FIPS module from 3.x to 4.x.
• New error kind variants: MessagesErrorKind::RequestLimitExceeded and OrderedErrorKind::RequestLimitExceeded (#1631), BatchErrorKind::PinnedClient (#1652). Exhaustive matches on these enums need a new arm.
• New public fields behind server_2_11: priority_timeout on consumer::Config and pull::Config, priority_groups on consumer::Info (#1653). Struct literals without ..Default::default() need updating (Info has no Default).
• Websocket errors behind ConnectError sources are now tokio-websockets 0.13 types, so downcasts to the 0.10 type stop matching (#1656).

Behaviour changes

• When the JetStream context timeout (ContextBuilder::timeout, Context::set_timeout) is set, it is now the only bound for every JetStream API request, whether it is lower or higher than the connection request_timeout. When it is not set, API requests keep using request_timeout (#1636).
• fetch(), batch() and sequence() return BatchErrorKind::PinnedClient on a PriorityPolicy::PinnedClient consumer. Use stream() or messages() instead (#1652).
• A pull consumer stream rejected with 409 Exceeded MaxRequest* now ends with MessagesErrorKind::RequestLimitExceeded instead of re-pulling forever. Batch and expiry defaults the user did not set are capped at the consumer's limits, and OrderedConfig::max_batch now reaches the server (#1631).
• A recreated ordered consumer is named {name}_{n}, using the configured name or the name the server gave the first consumer. The previous consumer is now deleted on recreation, unnamed ones included (#1626).
• ObjectStore::info(), and so put(), uses direct get when the stream allows it, so lookups of missing objects no longer count as JetStream API errors (#1632).
• For ws:// and wss:// on the default port, the Host header no longer includes the port. webpki-roots is no longer a dependency (#1656).

New Contributors

• @​macrauder made their first contribution in nats-io/nats.rs#1621

... (truncated)

Commits

• e22f657 Release async-nats/v0.51.0
• 4e70300 Redact secrets in ConnectInfo Debug output
• 1815112 Fix service error Display swapping code and status
• de95c75 Name the pull id helper for the pull it reads
• e10693c Split the pinned tests back into one behaviour each
• 37a030f Cover the 423 pin reset, get_last and the standby in pinned tests
• b61f5f5 Point the PinnedClient docs at stream().group(..).messages()
• b3252c7 Store the pin only when it changes
• 7df7694 Clarify why the pin is read from the last header
• 0f50af0 Support the pinned client priority policy in pull streams
• Additional commits viewable in compare view

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.

---

Dependabot commands and options

You can trigger Dependabot actions by commenting on this PR:

• @dependabot rebase will rebase this PR
• @dependabot recreate will recreate this PR, overwriting any edits that have been made to it
• @dependabot show <dependency name> ignore conditions will show all of the ignore conditions of the specified dependency
• @dependabot ignore this major version will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this minor version will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this dependency will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)

[coderabbitai]

Important

Review skipped

Bot user detected.

To trigger a single review, invoke the @coderabbitai review command.

Run configuration

• Source mode: Auto
• Repository: Unavailable
• Branch: Unavailable
• File: No configuration file from this repository applied
• Commit: Unavailable
• Layers: defaults
• Review profile: CHILL
• Plan: Advanced
• Run ID: 6001ce07-6370-46d1-9911-937c741af32d

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

• Trigger review

• Autofix · Keep fixing CodeRabbit findings and required CI, and resolving merge conflicts