Feature implementation from commits 92def3b..7bfd96a#2

Open

yashuatla wants to merge 15 commits into

feature-base-2from

yashuatla commented Jun 25, 2025

Owner

This PR contains changes from a range of commits from the original repository.

Commit Range: 92def3b..7bfd96a
Files Changed: 28 (25 programming files)
Programming Ratio: 89.3%

Commits included:

[FIXED] Add RemoveStatusListener method and fixFetch memory leak ([FIXED] Add RemoveStatusListener method and fixFetch memory leak nats-io/nats.go#1856)
Release v1.41.1 (Release v1.41.1 nats-io/nats.go#1851)
[FIXED] Use default timeout for ObjectStore.Get when no deadline is set on ctx ([FIXED] Use default timeout for ObjectStore.Get when no deadline is set on ctx nats-io/nats.go#1850)
[IMPROVED] Remove golang.org/x/text dependency (Remove golang.org/x/text dependency nats-io/nats.go#1849)
Release v1.41.0 (Release v1.41.0 nats-io/nats.go#1847)
[FIXED] Ensure object watcher stop closes the updates channel ([FIXED] Ensure object watcher stop closes the updates channel nats-io/nats.go#1844)
[ADDED] Consumer groups with Pinned and Overflow (Consumer groups with Pinned and Overflow nats-io/nats.go#1826)
[FIXED] Invalid default in documentation for OrderedConsumerConfig.InactiveThreshold ([FIXED] Invalid default in documentation for OrderedConsumerConfig.InactiveThreshold nats-io/nats.go#1845)
[ADDED] DefaultTimeout option for JetStream API requests ([ADDED] DefaultTimeout option for JetStream API requests nats-io/nats.go#1843)
[FIXED] Initialize rqch channel for immediate reconnection on ForceReconnect ([FIXED] Initialize rqch channel for immediate reconnection on ForceReconnect nats-io/nats.go#1846)
... and 5 more commits

piotrpio and others added 15 commits

April 2, 2025 13:06


          [ADDED] DefaultTimeout option for JetStream API requests

37db226

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          Revert "[ADDED] DefaultTimeout option for JetStream API requests"

6e95a6a

This reverts commit 37db226.


          [FIXED] Data race when reading current status in sub.StatusChanged an…

ea60063

…d nc.StatusChanged (nats-io#1841)

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [FIXED] Reset channel after closing in ForceReconnect (nats-io#1842)

77bc576

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [FIXED] Cancel Fetch and FetchBatch on reconnect (nats-io#1840)

f73b0c6

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
Co-authored-by: Alex Bozhenko <alexbozhenko@gmail.com>


          [FIXED] Initialize rqch channel for immediate reconnection on ForceRe…

1b40030

…connect (nats-io#1846)

This is a follow-up to nats-io#1842 which introduced an issue where `nc.rqch`
could be cleared before reading it in `doReconnect`.
This happened e.g. when an auth error triggered reconnect close to
calling `ForceReconnect` (made apparent by `TestAuthExpiredForceReconnect`
starting to be flaky).

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [ADDED] DefaultTimeout option for JetStream API requests (nats-io#1843)

495ec60

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [FIXED] Invalid default in documentation for OrderedConsumerConfig.In…

11ef899

…activeThreshold (nats-io#1845)

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [ADDED] Consumer groups with Pinned and Overflow (nats-io#1826)

93f7ce4

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
Co-authored-by: Jean-Noël Moyne <jnmoyne@gmail.com>
Co-authored-by: Piotr Piotrowski <piotr@synadia.com>


          [FIXED] Ensure object watcher stop closes the updates channel (nats-i…

9d1be03

…o#1844)

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          Release v1.41.0 (nats-io#1847)

e040f71

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [IMPROVED] Remove golang.org/x/text dependency (nats-io#1849)

8a2bd73

Signed-off-by: Neil Twigg <neil@nats.io>


          [FIXED] Use default timeout for ObjectStore.Get when no deadline is s…

e04728e

…et on ctx (nats-io#1850)

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          Release v1.41.1 (nats-io#1851)

50e6153

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>


          [FIXED] Add RemoveStatusListener method and fixFetch memory leak (nat…

7bfd96a

…s-io#1856)

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet