zishuo/nats.go
1
0
Fork 0
mirror of https://github.com/nats-io/nats.go.git synced 2025-10-06 09:07:15 +08:00
Code Issues Packages Projects Releases Wiki Activity
2,148 Commits 96 Branches 73 Tags
fix-create-consumer-empty-check
Commit Graph

27 Commits

Author SHA1 Message Date
Piotr Piotrowski
c0c5cc0c1f [FIXED] Handle empty response when creating a consumer 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-08-05 12:12:37 +02:00
Piotr Piotrowski
f73b0c639a [FIXED] Cancel Fetch and FetchBatch on reconnect (#1840) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
Co-authored-by: Alex Bozhenko <alexbozhenko@gmail.com>
 2025-04-02 13:21:34 +02:00
Piotr Piotrowski
a8924610a6 [ADDED] Timeout option for async publish (#1819) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-03-21 19:16:35 +01:00
Maurice van Veen
836ffd9148 [FIXED] Invalid subscription on ordered consumer in leaderless cluster 
Signed-off-by: Maurice van Veen <github@mauricevanveen.com>
 2025-02-24 20:33:39 +01:00
Piotr Piotrowski
c76a9a7a63 [ADDED] CleanupPublisher method for removing internal JetStream subscription (#1690) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-08-12 09:33:54 +02:00
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
7bdb6292d7 [FIXED] Validation in jetstream and KV (#1613) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-04-22 12:32:46 +02:00
Piotr Piotrowski
46be7408f6 [IMPROVED] Documentation for AccountInfo and ErrJetStreamNotEnabled (#1605) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-04-05 10:28:30 +02:00
Piotr Piotrowski
6dfefd9d7b [IMPROVED] Fetch and FetchBatch for draining and closed subscriptions (#1582) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-03-18 14:19:54 +01:00
Waldemar Quevedo
62af2df4e6 [IMPROVED] Error typo fix (#1563) 2024-02-26 21:28:50 +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
Jean-Noël Moyne
0c2a37d840 [ADDED] Client support for multi-subject transforms in sources and mirrors (#1359) 2023-09-20 08:21:30 +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
Waldemar Quevedo
f1e011b7a9 js: mirror test updates 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-09-20 08:19:54 +02:00
Piotr Piotrowski
79f092a2c0 [ADDED] Setting heartbeats in Fetch and FetchBatch in legacy API (#1402) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-16 08:36:06 +02:00
Piotr Piotrowski
c86a1a1548 Revert "[ADDED] Support for stream subject transform" (#1220) 
* Revert "[ADDED] Support for stream subject transform (#1200)"

This reverts commit c8608284eb.

* Revert "js: mirror test updates"

This reverts commit 424de47b25.
 2023-02-24 15:14:46 +01:00
Piotr Piotrowski
e059b4d17c [FIXED] Retry recreating ordered consumer on insufficient resources error (#1217) 2023-02-23 15:25:42 +01:00
Piotr Piotrowski
b466aade3a [FIXED] Stream and consumer name validation (#1219) 2023-02-23 15:25:19 +01:00
Waldemar Quevedo
424de47b25 js: mirror test updates 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-02-05 17:06:01 -08:00
Sam Tavakoli
b2ad744a01 PR Review feedback 
PR Review feedback over [slack](https://form3.slack.com/archives/C02281GJCJF/p1669986912679049).

Currently there are already users who are performing error string
comparision for this use case. To avoid introducing a breaking change
until there is a better way of handling these error messages, we will
retain the error message for the newly introduced canonical error
value.
 2022-12-02 16:45:57 +00:00
Sam Tavakoli
a52a9ec753 Provide a way to handle 409 Leadership Changed errors in client 
Without this change, it makes it hard for clients to handle consumer
errors relating to leadership changes differently from any other
error.

Follows same approach as ErrConsumerDeleted.
 2022-12-02 13:15:52 +00:00
Waldemar Quevedo
8499836133 Add ErrKeyExists that is compatible with errors.Is on kv.Create (#1136) 
* Add ErrKeyExists error that is compatible with errors.Is on kv.Create

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2022-11-17 13:33:30 -08:00
Maksim Meshkov
d80925c880 Fix some comments (#1128) 2022-11-11 15:24:22 +01:00
Piotr Piotrowski
4d7d95166a [ADDED] Extract ErrConsumerDeleted in Fetch() (#1125) 
* Extract ErrConsumerDeleted in Fetch()

* Update test/js_test.go

Co-authored-by: Waldemar Quevedo <wally@synadia.com>

Co-authored-by: Waldemar Quevedo <wally@synadia.com>
 2022-11-08 16:21:36 +01:00
Piotr Piotrowski
3c209f575f [UPDATED] Adjust consumer creation to nats-server v2.9.0 (#1080) 2022-09-16 17:46:40 +02:00
Waldemar Quevedo
67258a36f6 js: remove api error code from description 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2022-09-06 10:46:37 -07:00
Waldemar Quevedo
164805ca9c js: Add JetStreamError with API response details (#1047) 
* js: Add JetStreamError with more API response details
* js: Convert errors to JetStreamError and move to separate file

Signed-off-by: Waldemar Quevedo <wally@nats.io>
Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
 2022-08-23 10:16:28 -07:00