Golang client for NATS, the cloud native messaging system.
Fetch
and FetchBatch
when using heartbeats (#1601)https://github.com/nats-io/nats.go/compare/v1.34.0...v1.34.1
StatusChanged
method for subscription event notifications (#1570)ClientTLSConfig
option for setting TLS config with callbacks in Connect
(#1413)Compression
struct tag (#1559)Fetch
and FetchBatch
will no longer publish a pull request if the subscription is closed or draining (#1582)CONTRIBUTING.md
. Thanks @yordis for the contribution (#1574)respToken
in muxer. Thanks for the report @chgz (#1575)https://github.com/nats-io/nats.go/compare/v1.33.1...v1.34.0
This release fixes v1.33.0
release which was re-released with different tag, causing checksum mismatch when running go get github.com/nats-io/[email protected]
.
https://github.com/nats-io/nats.go/compare/v1.33.0...v1.33.1
This release introduces significant documentation improvements across jetstream
package components (JetStream, Object Store, and KeyValue).
TermWithReason
method on JetStream message (#1539)FetchHeartbeat
option for Fetch
and FetchBytes
(#1548)UpdateObjectStore
and CreateOrUpdateObjectStore
methods (#1550)UpdateKeyValue
and CreateOrUpdateKeyValue
methods (#1549)Drain()
infinite loop and add test for concurrent Next()
calls. Thanks to @mdawar for the contribution (#1525)jetstream
package (JetStream, KeyValue and ObjectStore) (#1532, #1537, #1551, #1553, #1555)nats.Secure
connect option. Thanks to @thorntonmc for the contribution (#1529)https://github.com/nats-io/nats.go/compare/v1.32.0...v1.33.0
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 (#1515)AccountInfo
. NOTE: This is only available since [email protected] (#1511)Subjects
on Stream.Info()
response when WithSubjectFilter()
option is used (#1517)Compression
option on KeyValueConfig
(#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)WithRetryAttempts()
and WithRetryWait()
options were ignored in PublishAsync()
(#1464)PullExpiry
validation in Consumer.Messages()
options (#1468)Stop()
method for ConsumeContext
and MessagesContext
. 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)nkeys
and compress
dependencies to latest versions (#1458, #1514)jetstream/README.md
. Thanks to @sebbbastien for the contribution (#1448)https://github.com/nats-io/nats.go/compare/v1.31.0...v1.32.0
TLSHandshakeFirst
option to perform TLS handshake before receiving the INFO
protocol message. Note: This option is not yet available in nats-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)go.mod
when using nats.go
. Thanks to @masumomo for the contribution (#1441)Consumer.Info()
when empty response and errors are returned (#1426)Consume
and Messages
(#1428)ConsumerInfo()
when empty response and errors are returned (#1426)jetstream/README.md
. Thanks @cbrake for the contribution (#1436)https://github.com/nats-io/nats.go/compare/v1.30.2...v1.31.0
https://github.com/nats-io/nats.go/compare/v1.30.1...v1.30.2
nats.PullHeartbeat()
causing pull heartbeat not being validated against deadline from nats.Context()
(#1414)https://github.com/nats-io/nats.go/compare/v1.30.0...v1.30.1
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.
SubjectTransform
support on streams (#1200)SubjectTransforms
on mirrors and sources (#1359, #1404)Compression
type on StreamConfig
(#1405)FirstSeq
on StreamConfig
(#1405)ConsumerLimits
on StreamConfig
(#1405)CreateConsumer
and UpdateConsumer
methods (#1379)micro
):
SubjectTransform
support on streams (#1200)SubjectTransforms
on mirrors and sources (#1359)Compression
type on StreamConfig
(#1405)FirstSeq
on StreamConfig
(#1405)ConsumerLimits
on StreamConfig
(#1405)https://github.com/nats-io/nats.go/compare/v1.29.0...v1.30.0
With this release, Object Store is out of experimental preview. Additionally, jetstream
package now supports KeyValue stores. Object store will be added to jetstream
in future release.
jetstream
(#1362)UpdatesOnly
option for KV watchers (#1378)UpdatesOnly
option for object store watchers (#1377)ErrorHandler()
on preparing connection string when reconnecting (#1397)MaxReconnects
. Thanks @mojixcoder for the contribution (#1394)experimental
notice from object store (#1399)FlusherTimeout
instead of 0 (#1398)https://github.com/nats-io/nats.go/compare/v1.28.0...v1.29.0