Name | Modified | Size | Downloads / Week |
---|---|---|---|
Parent folder | |||
README.md | 2025-07-29 | 1.6 kB | |
Release v1.44.0 source code.tar.gz | 2025-07-29 | 686.7 kB | |
Release v1.44.0 source code.zip | 2025-07-29 | 790.0 kB | |
Totals: 3 Items | 1.5 MB | 0 |
Changelog
Overview
This PR adds a PushConsumer
implementation to jetstream
, allowing easier migration to new API while maintaining usage of push consumers. For now it only supports the callback-based Consume()
, more consuming options will be added in future releases.
ADDED
- Core NATS:
UserCredentialBytes()
Conn
option (#1877)- JetStream:
PushConsumer
implementation injetstream
package- Expose
ClientTrace
inJetStreamOptions
(#1886) - Service API:
- Expose
WithEndpointPendingLimits
option (#1899) - Legacy KeyValue:
Error()
method toKeyLister
andKeyWatcher
interfaces (#1889)
FIXED
- Core NATS:
- Fix timeoutWriter not recovering after first error (#1896)
- JetStream:
Consumer.Next()
hangs after connection is closed (#1883)- Fixed stream info request for strict mode (#1887)
- Ordered consumer not closing on connection close (#1885)
- Return a more appropriate error when Subject Transform is not supported (#1416)
- Fix subject transform comparison. Thanks @erikmansson for the contribution (#1907)
- Legacy JetStream:
- Use timeout from
JetStreamContext
if no deadline is set on ctx (#1909) - KeyValue:
Keys()
andListKeys()
returning duplicates (#1884)- Fix subject prefix for the Create/Update operation in KV store. Thanks @SalvaChiLlo for the contribution (#1903)
CHANGED
- Change
DefaultSubPendingMsgsLimit
(#998)
Complete Changes
https://github.com/nats-io/nats.go/compare/v1.43.0...v1.44.0