This repository has been archived by the owner on Jan 19, 2024. It is now read-only.
fix(deps): update module github.com/nats-io/nats.go to v1.32.0 #103
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This PR contains the following updates:
v1.24.0
->v1.32.0
Release Notes
nats-io/nats.go (github.com/nats-io/nats.go)
v1.32.0
Compare Source
Changelog
Added
jetstream
package (#1450)Drain
method forConsumeContext
andMessagesContext
. UnlikeStop()
, 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 (#1515)AccountInfo
. NOTE: This is only available since [email protected] (#1511)Subjects
onStream.Info()
response whenWithSubjectFilter()
option is used (#1517)Compression
option onKeyValueConfig
(#1451)ListKeys
method for efficiently iterating over all keys in KV bucket (#1490)ResumeFromRevision
option for KV watcher. Thanks to @shadow3x3x3 for the contribution (#1489)Fixed
WithRetryAttempts()
andWithRetryWait()
options were ignored inPublishAsync()
(#1464)PullExpiry
validation inConsumer.Messages()
options (#1468)Stop()
method forConsumeContext
andMessagesContext
. Thanks to@evanofslack for the contribution (#1454)
Next()
method for ordered consumers (#1471, #1472)JetStream.Publish()
. Thanks to @oderwat for the contribution (#1474)PublishAsync()
(#1476)checkPending
logic (#1516)KV_
prefix when listing KeyValue store names (#1487)Improved
nkeys
andcompress
dependencies to latest versions (#1458, #1514)jetstream/README.md
. Thanks to @sebbbastien for the contribution (#1448)Complete Changes
v1.31.0
Compare Source
Changelog
Added
TLSHandshakeFirst
option to perform TLS handshake before receiving theINFO
protocol message. Note: This option is not yet available innats-server
(#1433)CreateOrUpdateStream
helper function to create a stream if it does not exist or update an existing stream. Thanks to @samanebi for the contribution (#1395)Fixed
go.mod
when usingnats.go
. Thanks to @masumomo for the contribution (#1441)Consumer.Info()
when empty response and errors are returned (#1426)Consume
andMessages
(#1428)ConsumerInfo()
when empty response and errors are returned (#1426)Improved
jetstream/README.md
. Thanks @cbrake for the contribution (#1436)Complete Changes
v1.30.2
Compare Source
Changelog
Fixed
Complete Changes
v1.30.1
Compare Source
Changelog
Fixed
nats.PullHeartbeat()
causing pull heartbeat not being validated against deadline fromnats.Context()
(#1414)Complete Changes
v1.30.0
Compare Source
Changelog
Overview
This release focuses on adding features introduced in [email protected]. Among other things, this includes setting multiple filter subjects for a consumer, configuring stream subject transform, as well as setting stream and consumer metadata.
Added
SubjectTransform
support on streams (#1200)SubjectTransforms
on mirrors and sources (#1359, #1404)Compression
type onStreamConfig
(#1405)FirstSeq
onStreamConfig
(#1405)ConsumerLimits
onStreamConfig
(#1405)CreateConsumer
andUpdateConsumer
methods (#1379)micro
):SubjectTransform
support on streams (#1200)SubjectTransforms
on mirrors and sources (#1359)Compression
type onStreamConfig
(#1405)FirstSeq
onStreamConfig
(#1405)ConsumerLimits
onStreamConfig
(#1405)Complete Changes
v1.29.0
Compare Source
Changelog
Overview
With this release, Object Store is out of experimental preview. Additionally,
jetstream
package now supports KeyValue stores. Object store will be added tojetstream
in future release.Added
jetstream
(#1362)UpdatesOnly
option for KV watchers (#1378)UpdatesOnly
option for object store watchers (#1377)ErrorHandler()
on preparing connection string when reconnecting (#1397)Improved
MaxReconnects
. Thanks @mojixcoder for the contribution (#1394)Changed
experimental
notice from object store (#1399)FlusherTimeout
instead of 0 (#1398)Fixed
Complete Changes
v1.28.0
Compare Source
Changelog
Overview
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
HeadersOnly
field onOrderedConsumerConfig
(#1327)WithStreamListSubject()
option to filter results ofListStreams()
andStreamNames()
by stream name (#1312)Improved
dev
andmain
branches ofnats-server
to tests in CI (#1336)parse_test.go
. Thanks @YukiBobier for the contribution (#1334)jetstream/README.md
(#1347, #1350)Changed
interface{}
withany
across the codebase (#1332)NakWithDelay
to separate method, instead of it being an option onNak()
(#1337)context.Background()
orcontext.TODO()
is used (#1348)Fixed
OrderedConsumer()
(#1317)Next()
blocking indefinitely after callingStop()
. Thanks @mdawar for the contribution (#1344)Consume()
(#1345)PublishAsync()
blocking published due toPublishAsyncMaxPending
not being reset on reconnect (#1346)PublishAsync()
blocking published due toPublishAsyncMaxPending
not being reset on reconnect (#1346)Complete Changes
v1.27.1
Compare Source
Changelog
Improved
FetchBytes()
injetstream/README.md
. Thanks @fabiant7t for the contribution! (#1329)Fixed
nats.Conn
for pull requests. Thanks @oderwat for the contribution! (#1322)nats.Context
is used. Thanks @anthonyjacques20 for the contribution! (#1314)Durable
not set on server versions prior to 2.9.0 (#1325)Complete Changes
v1.27.0
Compare Source
Changelog
Overview
This release focuses on improvements to new JetStream API and Service API (
micro
) preview functionalities.Added
StreamNameBySubject()
method for stream discovery based on provided subject (#1292)Improved
Consume()
andMessages()
(#1303)Changed
AddConsumer
toCreateOrUpdateConsumer
. This change is introduced in anticipation for separation of create and update operations innats-server
(#1300)AckPolicy
toAckPolicyExplicit
(#1278)PullThresholdBytes
type name (#1300)ConsumerConfig
(#1300)context.Context
fromPublishAsync
andPublishMsgAsync
(#1300)micro
):INFO
schema (#1277)STATS
response toINFO
responseINFO
now returnsendpoints
object, containing subject, name and metatada. This replacessubject
field.Fixed
ErrNoHeartbeat
. Thanks @alexisvisco for the contibution! (#1291)jetstream/README.md
). Thanks @bojanz for the contribution! (#1295)Put()
andPutBytes()
(#1282)Complete Changes
v1.26.0
Compare Source
Changelog
Overview
This release adds beta functionality of JetStream simplified API. The goal of this API is to simplify and streamline stream and consumer management, as well as leverage pull consumers for continuous message retrieval. We encourage you to give it a try and post your feedback!
You can find more details on the new API here
Added
jetstream
directory (https://github.com/nats-io/nats.go/blob/main/jetstream/README.md) (#1273).ConsumerName()
subscribe option to setName
inConsumerConfig
when creating a consumer (#1263)SkipConsumerLookup()
subscribe option to bypass verifying if the consumer exists before consumer creation (#1265)Improved
micro
directory (#1271)micro
(#1240)Changed
Subscribe()
when name is not provided to leverage 2.9.0 consumer create server API (#1261, #1263)micro
):api_url
andSCHEMA
endpoint (#1270)Fixed
TestJetStreamConcurrentQueueDurablePushConsumers
test (#1267)Complete Changes
v1.25.0
Compare Source
Changelog
Added
micro
):Improved
TestJetStreamStreamInfoWithSubjectDetails
test (#1225)Durable()
option comment. Thanks @jlvallelonga fot the contribution (#1229)Changed
Fetch()
/FetchBatch()
. Additionaly,FetchBatch()
nowverifies whether a request timeout was received for a current pull request (#1237, #1238)
Complete Changes
Configuration
📅 Schedule: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined).
🚦 Automerge: Disabled by config. Please merge this manually once you are satisfied.
♻ Rebasing: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox.
🔕 Ignore: Close this PR and you won't be reminded about this update again.
This PR has been generated by Mend Renovate. View repository job log here.