This release focuses on a set of changes and improvements in new JetStream API. With this release, JetStream API is out of preview.
Additionally, with this release support for go version < 1.18.0 is dropped, due to usage of any type in codebase.
Added
JetStream:
HeadersOnly field on OrderedConsumerConfig (#1327)
WithStreamListSubject() option to filter results of ListStreams() and StreamNames() by stream name (#1312)
Improved
Added dev and main branches of nats-server to tests in CI (#1336)
Core NATS:
Fixed incorrect test case in parse_test.go. Thanks @YukiBobier for the contribution (#1334)
JetStream:
Fix typos and doc comments in new JetStream API. Thanks @mdawar for the contribution (#1339)
Fixed and slightly enhanced the basic example in jetstream package. Thanks to @pwntr for the contribution (#1340)
Improvements in in jetstream/README.md (#1347, #1350)
Changed
Replace interface{} with any across the codebase (#1332)
JetStream:
[BREAKING CHANGE] Move NakWithDelay to separate method, instead of it being an option on Nak() (#1337)
[BREAKING CHANGE] Simplified API for listing streams and stream names (#1312)
Add default timeout when context.Background() or context.TODO() is used (#1348)
Fixed
JetStream:
Create consumer when calling OrderedConsumer() (#1317)
Unset start time for ordered consumer on reset (#1341)
Fixed Next() blocking indefinitely after calling Stop(). Thanks @mdawar for the contribution (#1344)
Invalid missing heartbeat errors in Consume() (#1345)
Fixed PublishAsync() blocking published due to PublishAsyncMaxPending not being reset on reconnect (#1346)
Legacy JetStream:
Fixed PublishAsync() blocking published due to PublishAsyncMaxPending not being reset on reconnect (#1346)
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 merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
- `@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)
Bumps github.com/nats-io/nats.go from 1.27.1 to 1.28.0.
Release notes
Sourced from github.com/nats-io/nats.go's releases.
Commits
3e4bc5aRelease v1.28.0 (#1353)4354bd9Move new JetStream API docs to top level README (#1352)83e1310[IMPROVED] Fixed + slightly enhanced the basic example in jetstream package (...3818089[FIXED] PublishAsyncMaxPending not reset after server disconnect (#1346)03cb7ad[CHANGED] Simplified API for listing streams and stream names, added option t...cf491db[CHANGED] Add default timeout in JetStream when empty context is used (#1348)7572f3b[CHANGED] Use memory storage for ordered consumer (#1349)4973881js: shorten timeout in readme (#1350)c213303[FIXED] Invalid heartbeat errors in Consume() (#1345)79f5f2fFixes to jetstream/readme (#1347)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 merge` will merge this PR after your CI passes on it - `@dependabot squash and merge` will squash and merge this PR after your CI passes on it - `@dependabot cancel merge` will cancel a previously requested merge and block automerging - `@dependabot reopen` will reopen this PR if it is closed - `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually - `@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)