Release v1.32.0

[piotrpio]

Added

• JetStream:
  • ObjectStore is now available as part of jetstream package ([ADDED] ObjectStore API in jetstream package #1450)
  • Drain method for ConsumeContext and MessagesContext. Unlike Stop(), in addition to unsubscribing and canceling the existing pull requests it will ensure that all messages already stored in client buffer will be available for processing ([ADDED] Drain for jetstream consume methods #1515)
  • Return account reservations on AccountInfo. NOTE: This is only available since nats-server@v2.10.8 ([ADDED] Return account reservations on AccountInfo #1511)
  • Paging Subjects on Stream.Info() response when WithSubjectFilter() option is used ([ADDED] Paging subjects in stream info #1517)
• KeyValue:
  • Compression option on KeyValueConfig ([ADDED] Compression option on KV bucket #1451)
  • ListKeys method for efficiently iterating over all keys in KV bucket ([ADDED] ListKeys method for listing kv keys #1490)
  • ResumeFromRevision option for KV watcher ([ADDED] StartRevision option to KV watcher #1489)

Fixed

• Legacy JetStream:
  • Fixed and issue where ordered consumer was recreated with different name format than the original (Remove ordered consumer on reset and fix recreated consumer name #1449)
• JetStream:
  • Fixed an issue where WithRetryAttempts() and WithRetryWait() options were ignored in PublishAsync() ([ADDED] Retry PublishAsync on no responders #1464)
  • Fixed invalid PullExpiry validation in Consumer.Messages() options ([FIXED] Invalid PullExpiry validation #1468)
  • Fixed race condition on Stop() method for ConsumeContext and MessagesContext . ([FIXED] Eliminate race condition in pull subscription stop #1454)
  • Fixed issues with Next() method for ordered consumers (Fix ordered consumer Next timeout #1471, Fix Ordered Consumer for Next #1472)
  • Fixed ignoring a private inbox prefix in JetStream.Publish() (Fix for ignoring a private inbox prefix in jetstream publish. #1474)
  • Fixed invalid PAF id for PublishAsync() (Fix async publish PAF id #1476)
  • Fixed race condition when getting pull subscriptions in ordered consumer ([FIXED] Race condition when getting pull subscriptions in ordered consumer #1497)
  • Fixed several issues in checkPending logic ([FIXED] Invalid checkPending logic #1516)
• KeyValue:
  • Removed KV_ prefix when listing KeyValue store names (Fix prefix in key value stores #1487)
• Service API:
  • Fixed race condition when adding endpoints concurrently (fix: race condition when adding endpoints from goroutine #1484)

Improved

• Bumped nkeys and compress dependencies to latest versions (Update nkeys and other deps #1458, Bump nkeys version #1514)
• Fixed broken link in jetstream/README.md (Update README.md #1448)
• Improvements for code quality across the library (chore(jetstream): cleanup #1498, chore: use errors.Is for err handling, and use skipped bool #1500)
• Legacy JetStream:
  • Library now attempts to delete ordered consumer before creating new one to avoid piling up consumers on reset (Remove ordered consumer on reset and fix recreated consumer name #1449)
• Service API:
  • Added compatibility tests for Service API (Compatibility tests for micro #1443)

[Jarema]

LGTM