zishuo/nats.go
1
0
Fork 0
mirror of https://github.com/nats-io/nats.go.git synced 2025-09-26 20:41:41 +08:00
Code Issues Packages Projects Releases Wiki Activity
2,173 Commits 94 Branches 72 Tags
main
Commit Graph

93 Commits

Author SHA1 Message Date
Piotr Piotrowski
3416ed073b [ADDED] New fields in ClusterInfo (#1935) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-09-22 17:00:03 +02:00
Piotr Piotrowski
7af9697b58 [FIXED] Handle empty response when creating a consumer (#1912) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-08-19 17:12:39 +02:00
Piotr Piotrowski
3bd15a8026 [FIXED] Use timeout from JetStreamContext if no deadline is set on ctx 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2025-07-24 15:34:53 +02: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
Engin Açıkgöz
8bd17360be [IMPROVED] Use errors.New instead of fmt.Errorf where possible (#1707) 2024-09-19 14:22:16 +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
Kazmer Dome
833574b050 [IMPROVED] Added documentation for StreamConfig in jsm.go (#1625) 2024-05-16 23:57:58 +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
4b3ba718d0 [IMPROVED] AddConsumer documentation (#1555) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-02-14 09:33:38 +01:00
Piotr Piotrowski
cd2f25af74 [ADDED] Return account reservations on AccountInfo (#1511) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2024-01-12 12:59:18 +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
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
4d43218266 [FIXED] Stream create response test for sources being present in the response (#1420) 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-27 09:20:01 +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
Jean-Noël Moyne
7d66f4ada3 Remove the single subject transform destination field from StreamSource (config and info) 
see https://github.com/nats-io/nats-server/pull/4557
 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
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
Jean-Noël Moyne
78f3964975 [ADDED] Support for stream subject transform (#1200) 
* Adds support for stream subject transform

Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
 2023-09-20 08:19:54 +02:00
Piotr Piotrowski
429273afbe [FIXED] Creating ephemeral consumers on server < 2.9.0 (#1325) 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-06-22 09:16:14 +02:00
Piotr Piotrowski
8d9ad1b995 Make consumer create idempotent 2023-05-23 11:55:56 +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
b466aade3a [FIXED] Stream and consumer name validation (#1219) 2023-02-23 15:25:19 +01:00
Jean-Noël Moyne
c8608284eb [ADDED] Support for stream subject transform (#1200) 
* Adds support for stream subject transform

Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
 2023-02-05 16:41:35 -08:00
Jean-Noël Moyne
eada5ecccb [IMPROVE] Don't re-define the consumer if there's no change in the consumer config (#1185) 2023-01-10 09:44:38 +01:00
Piotr Piotrowski
d50c137506 [FIXED] Pass opts to ConsumerInfo call in AddConsumer (#1176) 2023-01-04 09:58:30 +01:00
Maksim Meshkov
d80925c880 Fix some comments (#1128) 2022-11-11 15:24:22 +01:00
Derek Collison
6bd78372ce Support stream alternates 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-11-02 14:38:25 -07:00
Tomasz Pietrek
7ac1087d8c [CHANGED] Make lookupStreamBySubject public (#1114) 2022-10-31 16:30:55 +01:00
Derek Collison
1d9796fd33 Added support for KV mirrors and sources and updated state for proper Put() and Get() with mirrors and across domains, e.g. leafnodes. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-10-19 16:01:39 -07:00
Waldemar Quevedo
543e628f4b Merge pull request #1095 from nats-io/js-account-info-typo 
js: Fix typo in AccountInfo JSON to handle Tiers
 2022-10-07 04:11:04 -07:00
Piotr Piotrowski
b142f6053b Add DiscardNewPerSubject to stream config (#1102) 2022-10-06 17:54:54 +02:00
Waldemar Quevedo
ac7358d427 js: Fix typo in AccountInfo JSON to handle Tiers 2022-09-27 11:40:34 -07:00
Piotr Piotrowski
3c209f575f [UPDATED] Adjust consumer creation to nats-server v2.9.0 (#1080) 2022-09-16 17:46:40 +02:00
jnmoyne
65796fc5ab [CHANGED] StreamInfo() will now return all subjects when requested 
If a subject filter is specified in the StreamInfoRequest{} option,
then all matching subjects will be returned and not be capped to
the server limit of 100,000. It is internally using pagination
that was added in the server PR: https://github.com/nats-io/nats-server/pull/3454
 2022-09-15 16:00:45 -06:00
Piotr Piotrowski
225c55795f [ADDED] Listing buckets and bucket names (#1074) 2022-09-15 14:00:37 +02:00
Derek Collison
f68442136d Mirrors can answer direct gets potentially so removing error condtion. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-06 07:39:37 -07:00
Derek Collison
bf8b693aff Make explicit for server processing 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-05 10:53:52 -07:00
Piotr Piotrowski
c3a557a44c Add subject filtering when listing streams (#1062) 2022-08-31 14:30:53 +02:00
Piotr Piotrowski
5af7980903 Fix paging in stream and consumer names listing (#1060) 2022-08-31 14:01:14 +02: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
Piotr Piotrowski
82272a03d9 Address review comments 2022-08-16 09:54:34 +02:00
Piotr Piotrowski
4d7a668a95 Use JetStream error codes, extract ErrConsumerNameAlredyInUse 2022-08-11 17:58:52 +02:00
Ivan Kozlovic
45e6198e7d Temporary code change so that server PR can run tests 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-08-10 13:00:57 -06:00
Piotr Piotrowski
2f6bef5929 Update StreamSourceInfo struct 2022-08-10 10:49:46 +02:00
Piotr Piotrowski
2a932dd525 Add SecureDeleteMsg method to JetStreamManager 2022-08-04 19:05:31 +02:00
Jeremy Saenz
15f0480911 Remove server version check 2022-08-03 10:04:15 -07:00
Jeremy Saenz
1eb8a22c21 Started implementation of direct gets by subject 2022-08-03 09:50:45 -07:00
Piotr Piotrowski
8d71591e6b Update account info schema 2022-08-02 13:40:53 +02:00