39 Commits

Author SHA1 Message Date
Piotr Piotrowski
94fa0cb994 Deprecate encoded connections (#1674)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2024-07-23 16:46:25 +02:00
Piotr Piotrowski
364bbefd06 [ADDED] Force reconnect (#1624)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2024-05-17 09:37:52 +02:00
Joachim Bauch
d7fda7d0cc [IMPROVED] Fix typos in comments. (#1547)
Signed-off-by: Joachim Bauch <bauch@struktur.de>
2024-02-07 21:22:19 +01:00
Piotr Piotrowski
b868e2a2d6 Update dates in licence headers (#1445)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2023-10-17 18:44:27 +02:00
Piotr Piotrowski
8ca661bdb1 [ADDED] Support for multiple subject filters on consumers (#1214)
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
2023-09-20 08:19:54 +02:00
Piotr Piotrowski
8faa842dda [ADDED] SkipConsumerLookup option in js.Subscribe() (#1265)
Signed-off-by: Waldemar Quevedo <wally@nats.io>
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
Co-authored-by: Waldemar Quevedo <wally@nats.io>
2023-05-16 17:48:50 +02:00
Waldemar Quevedo
65b787031b Add SkipTLSHandshake small interface to CustomDialer
Signed-off-by: Waldemar Quevedo <wally@nats.io>

Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
2022-11-29 15:23:25 -08:00
Deepak Sah
866ce0858b [ADDED] Option to set memory storage to true for a consumer (#1078) 2022-09-15 21:12:45 +02:00
Deepak Sah
fcc7c44324 Allow setting consumer replicas though options (#1019)
[ADDED] Allow setting consumer replicas though options
2022-07-29 12:07:11 -06:00
Muhammad Faizan
c47689c9ec updated example_tests 2022-03-25 10:00:45 +01:00
Muhammad Faizan
f0dcbad53d Added BackOff helper method to set backoff through subOpts 2022-03-22 14:09:28 +01:00
Ben Wells
814f4cca9d Fix typo: druable -> durable 2022-01-12 20:14:26 +00:00
Ivan Kozlovic
e077154668 Addresses comments change requests based on code review
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-08-16 12:18:15 -06:00
Ivan Kozlovic
45b7e7725b JetStream: lot of changes
They will be described in the release notes, but gist:

Added:
- `DeliverSubject()` option to configure the deliver subject of a JetStream consumer created by the `js.Subscribe()` call (and variants)
- `BindDeliverSubject()` option to subscribe directly to a JetStream consumer deliver subject (bypassing any lookup or JetStream consumer creation)
- Fields `DeliverGroup` in `ConsumerConfig`, `PushBound` in `ConsumerInfo`. They help making prevent incorrect subscriptions to JetStream consumers
- Field `Last` in `SequencePair`

Changed:
- With a `PullSubscription`, calling `NextMsg()` or `NextMsgWithContext()` will now return `ErrTypeSubscription`. You must use the `Fetch()` API
- If the library created internally a JetStream consumer, the consumer will be deleted on `Unsubscribe()` or when the `Drain()` completes
- Fail multiple instances of a subscription on the same durable push consumer (only one active at a time). Also, consumers now have the concept of `DeliverGroup`, which is the queue group name they are created for. Only queue member from the same group can attach to this consumer, and a non queue subscription cannot attach to it. Note that this requires server v2.3.5
- Attempting to create a queue subscription with a consumer configuration that has idle heartbeats and/or flow control will now result in an error

Fixed:
- Possible lock inversion
- JetStream consumers could be incorrectly deleted on subscription's `Unsubscribe()`

Resolves #785
Resolves #776
Resolves #775
Resolves #748
Resolves #747

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-08-15 11:47:32 -06:00
Ivan Kozlovic
ea036d7532 Merge pull request #710 from wallyqs/godoc-context-example
Add godoc example for JS context functions
2021-05-03 12:42:53 -06:00
Jaime Piña
a2f745aebf Fix staticcheck lint 2021-05-03 11:32:58 -07:00
Waldemar Quevedo
e7b6eda230 Add godoc example for JS context functions
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-04-12 14:00:04 -07:00
Waldemar Quevedo
1645e080ca Add consumer to msg Metadata
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-04-12 12:49:23 -07:00
Waldemar Quevedo
6f01c1e172 js: Add godoc examples for JetStream context
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-04-01 15:12:51 -07:00
Derek Collison
234e9d8119 Updates for rename and go.mod support
Signed-off-by: Derek Collison <derek@nats.io>
2019-05-10 13:24:55 -07:00
Derek Collison
2f0e8883ae CNCF, move to Apache 2 2018-03-17 13:36:48 -07:00
Ivan Kozlovic
7fb0d8ee11 Fixed misspell invocation and some misspelled words 2017-04-21 10:12:30 -06:00
Derek Collison
c1c9ec3f56 Rename of repo to go-nats 2016-11-20 11:50:22 -08:00
Derek Collison
90f704d816 Better option handling for TLS connections 2016-01-16 17:17:16 -08:00
Derek Collison
9e99c311db lint fixups 2016-01-16 10:44:11 -08:00
Derek Collison
6f386d8b0c travis/test fixups 2015-09-17 11:36:17 -07:00
Derek Collison
e52a3ae745 Moved tests over, reconnect and test cleanup 2015-09-16 22:22:25 -07:00
Derek Collison
078e19b430 Moved repo link 2015-06-19 16:44:58 -07:00
Derek Collison
1e360f44df Fixed race condition on reconnects that prevented reconnectCBs 2013-10-15 09:39:40 -07:00
Derek Collison
ff60c4c187 Added channel examples 2013-06-22 07:59:03 -07:00
Ken Robertson
abb9f46bf5 gofmt 2013-05-30 23:15:42 -07:00
Ken Robertson
21172c9a56 Revert "Remove examples"
This reverts commit 6a934388ea.
2013-05-30 23:11:54 -07:00
Tim Labeeuw and Tony Hansmann
6a934388ea Remove examples 2013-05-23 10:35:52 -07:00
Mark Veronda
3741a705c4 Fixed type-os and standardized some comments 2012-12-04 16:31:11 -08:00
Derek Collison
132bc70e96 Added EncodedConn examples 2012-10-03 10:47:40 -07:00
Derek Collison
b0e676cf7b gofmt fixes 2012-09-25 16:57:39 -07:00
Derek Collison
fae08b04b2 Remove expected output 2012-08-16 15:25:17 -07:00
Derek Collison
2859862ebe syntax typo 2012-08-16 15:07:57 -07:00
Derek Collison
d177c62c7a Removed Connection interface, used Conn struct directly 2012-08-16 15:06:54 -07:00