zishuo/nats.go
1
0
Fork 0
mirror of https://github.com/nats-io/nats.go.git synced 2025-10-01 06:42:08 +08:00
Code Issues Packages Projects Releases Wiki Activity
2,148 Commits 95 Branches 73 Tags
fix-reconnect-handler
Commit Graph

236 Commits

Author SHA1 Message Date
Piotr Piotrowski
c93af50962 [ADDED] KeyValue per key TTL support and limit markers (#1864) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-05-02 09:32:09 +02:00
Piotr Piotrowski
7bfd96a7cf [FIXED] Add RemoveStatusListener method and fixFetch memory leak (#1856) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-04-16 17:31: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
c758f7a985 [FIXED] Set context from option when creating consumer in js.Subscribe (#1835) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-03-25 20:14:07 +01:00
Piotr Piotrowski
4ed447c7cf [ADDED] Add per msg ttl on publish (#1825) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-03-21 21:23:46 +01: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
Piotr Piotrowski
662490e4ed [FIXED] Avoid ack id collision in PublishAsync (#1812) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-03-19 16:17:17 +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
4732ef6eef [FIXED] Fix tests against main server branch (#1764) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-01-15 20:05:42 +01:00
Piotr Piotrowski
6f4e85afdb [FIXED] Add missing nats prefix to error (#1753) 
Signed-off-by: Piotr Piotrowski piotr@synadia.com
 2024-12-17 17:05:35 +01:00
Piotr Piotrowski
d6eaa84a03 [ADDED] Creating iterators for sync subscriptions (#1728) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-12-17 15:06:23 +01:00
Piotr Piotrowski
6bc41598cc [FIXED] Race in MessageBatch (#1743) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-12-17 15:05:37 +01:00
Engin Açıkgöz
8bd17360be [IMPROVED] Use errors.New instead of fmt.Errorf where possible (#1707) 2024-09-19 14:22:16 +02:00
pranavmehta94
6f181d34d2 [IMPROVEMENT] Added client retry for async publish in legacy JetStream API (#1695) 2024-08-14 16:55:43 +02: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
af10233f2f [FIXED] Change Fetch client timeout to a higher value (#1689) 
* [FIXED] Change Fetch client timeout to a higher value

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

* Set the maximum diff on timeouts

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

---------

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-08-12 09:32:56 +02:00
Piotr Piotrowski
c97f022375 [FIXED] Async publish error handling on disconnect (#1592) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-04-02 22:34:03 +02:00
Piotr Piotrowski
42076581a5 [FIXED] Race condition in Fetch and FetchBatch when using heartbeats (#1601) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-04-02 17:24:17 +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
Piotr Piotrowski
d6a64d3e39 [IMPROVED] Add legacy api warnings on old JetStream API (#1553) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-02-09 11:44:08 +01:00
Sasha Melentyev
98430acd80 [IMPROVED] Use errors.Is for err handling, and use skipped bool (#1500) 
Signed-off-by: Sasha Melentyev <sasha@m8.ru>
 2024-01-11 16:36:58 +01:00
Piotr Piotrowski
245bd2bf5f [FIXED] Handle several ignored errors (#1496) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-12-15 14:00:12 +01:00
Tomasz Pietrek
bb64e1b6e3 Fix async pub paf id for old js API 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-11-28 15:41:51 +01:00
Piotr Piotrowski
efb3ab699e [IMPROVED] Remove ordered consumer on reset and fix recreated consumer name (#1449) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-10-27 10:51:03 +02:00
Piotr Piotrowski
ff131adbb1 [FIXED] Panic on ConsumerInfo when empty reponse and errors are returned (#1426) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-10-03 20:05:18 +02:00
Piotr Piotrowski
895e54285c [FIXED] Fix pull heartbeat validation 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-25 15:18:15 +02:00
Piotr Piotrowski
8ce44e0ce9 [ADDED] Missing fields on StreamConfig for 2.10.0 release (#1405) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-20 08:21:33 +02:00
Piotr Piotrowski
859b5495d7 [ADDED] Stream and consumer metadata (#1384) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-20 08:21:33 +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
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
3acdc379d4 [FIXED] Sending publish async completion signal after reconnect (#1391) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-12 16:24:09 +02:00
Paolo TETI
6b9c74529b [FIXED] typos in comments and error messages 
Fixes typos in comments and error message found using codespell.
 2023-08-28 21:37:35 +02:00
Piotr Piotrowski
3af379dccf [ADDED] KV implementation in new JetStream API (#1362) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-08-25 12:36:54 +02:00
Piotr Piotrowski
b3f214900f [FIXED] Resetting ordered consumer after context timeout (#1360) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-08-04 14:39:59 +02:00
Ante Gulin
f95d02a8a0 [IMPROVED] Fix typo in doc comment for SkipConsumerLookup (#1355) 2023-07-31 12:04:59 +02:00
Piotr Piotrowski
3818089dbb [FIXED] PublishAsyncMaxPending not reset after server disconnect (#1346) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-07-19 11:51:42 +02:00
Byron Ruth
fd05bbb000 [FIXED] Unset start time for ordered consumer on retry (#1341) 
If an ordered consumer was configured with a start time, on
retry, the copied consumer config would start with sequence
but the existing start time opt would conflict causing
a config error.

Fix #1281

Signed-off-by: Byron Ruth <byron@nats.io>
 2023-07-07 13:46:08 +02:00
Piotr Piotrowski
76b92fb24f [IMPROVED] Replace empty interface with any (#1332) 2023-06-27 12:40:21 +02:00
Piotr Piotrowski
1bb385f044 Revert "[IMPROVED] Replace empty interface with any" (#1330) 
This reverts commit af3706ecfd.
 2023-06-22 10:52:40 +02:00
Piotr Piotrowski
61b0ce9bd4 [IMPROVED] Replace empty interface with any (#1315) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-06-14 20:19:55 +02:00
Piotr Piotrowski
d2c31e4f78 [FIXED] Cleanup reply sub after putting object (#1282) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-06-06 23:29:45 +02:00
Piotr Piotrowski
2396e9d12c Merge branch 'main' of https://github.com/nats-io/nats.go into jsv2 2023-05-23 12:04:18 +02:00
Piotr Piotrowski
b31e5f64c5 Merge branch 'main' of https://github.com/nats-io/nats.go into jsv2 
Improve readme

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

Fix msg size calculation

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

Add connection event listeners

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

Fix leaky goroutines in tests

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-05-23 12:04:01 +02:00
Piotr Piotrowski
ac403323c4 Iterator for pull consumer, refine API and fix bugs 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-05-23 11:56:55 +02:00
Piotr Piotrowski
c8b7b4bfa3 Move parse.go to internal directory 2023-05-23 11:56:26 +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
1537c0b544 Fix staticcheck, use single function for getHash 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-05-11 17:41:35 -07:00
Waldemar Quevedo
34464fbd4b js: add ConsumerName option 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-05-11 17:30:15 -07:00
Waldemar Quevedo
19782c0578 js: use similar ephemeral consumer names as server 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-05-11 17:03:24 -07:00
Piotr Piotrowski
d313991b62 [CHANGED] Generate consumer name in Subscribe() when name is not provided (#1261) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-05-11 16:56:10 +02:00