gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 19:14:41 -07:00
Code Issues Packages Projects Releases Wiki Activity
6,292 Commits 30 Branches 48 Tags
b86e941ce4f55ccfb8e9326ad1feafe42ecca73e
Commit Graph

6292 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Derek Collison
b86e941ce4 tweak lost quorum reporting 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-07 10:57:01 -07:00
Derek Collison
e3e092d5f3 Merge pull request #3445 from nats-io/js-group-leaderless 
Suppress leaderless claims if JetStream just started.
 2022-09-07 09:02:28 -07:00
Derek Collison
fbf2233e4a Only complain about leaderless group with previous leader if we know jetstream has been running for some threshold. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-07 08:47:55 -07:00
Derek Collison
a4b6b2041f Bump to 2.9.0-RC.17 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-06 17:02:13 -07:00
Ivan Kozlovic
fbc7c25520 Merge pull request #3435 from nats-io/mon-js-reserved-stats 
js: add per account reserved mem/store bytes
 2022-09-06 18:01:22 -06:00
Waldemar Quevedo
46d73eddae js: add per account reserved mem/store bytes 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2022-09-06 16:43:10 -07:00
Derek Collison
cf517e45b0 Merge pull request #3442 from nats-io/pull-noack-ok 
NoAck allowed now on pull consumers
 2022-09-06 15:20:00 -07:00
Derek Collison
84b95be56e NoAck allowed now on pull consumers 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-06 15:19:17 -07:00
Derek Collison
e4a6b6bc94 Merge pull request #3441 from nats-io/no-auto-direct-get 
Do not auto-promote direct get functionality.
 2022-09-06 13:35:46 -07:00
Derek Collison
9c3bd17059 Updates to tests 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-06 13:33:39 -07:00
Derek Collison
b850a95d4c Remove auto-promotion of direct get. Force stream config to set AllowDirect to true. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-06 13:33:39 -07:00
Derek Collison
f190b6b6f4 Upgrade packages 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-09-06 13:33:39 -07:00
Ivan Kozlovic
8a71c642c6 Merge pull request #3439 from mprimi/nats-pub-benchmark 
NATS Publish benchmark
 2022-09-06 11:24:06 -06:00
Marco Primi
e498781921 NATS Publish benchmark 2022-09-06 09:52:45 -07:00
Ivan Kozlovic
35d7e9f280 Merge pull request #3440 from nats-io/fix_1066 
[FIXED] JetStream: Restarted queue subscriptions may not receive msgs
 2022-09-06 09:16:45 -06:00
Ivan Kozlovic
16eb2af0ec [FIXED] JetStream: Restarted queue subscriptions may not receive msgs 
The server was not properly handling queue subscriptions internal
notifications which could lead to messages not being delivered
to applications using a queue group to consume from a JetStream
consumer after they were restarted.

Resolves #1066

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-05 16:38:43 -06:00
Ivan Kozlovic
434bc34713 Merge pull request #3436 from nats-io/fix_lexer_convenient_number 
Fixed lexer changes made in #3434
 2022-09-03 20:37:38 -06:00
Ivan Kozlovic
6ebbb4a41a Fixed lexer changes made in #3434 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-03 20:02:25 -06:00
Ivan Kozlovic
1a9b3c49c0 Merge pull request #3434 from nats-io/fix_3431 
[FIXED] Parsing of strings starting with numbers and K/G/etc.. suffix
 2022-09-02 20:51:00 -06:00
Ivan Kozlovic
86d20aa5e6 [FIXED] Parsing of strings starting with numbers and K/G/etc.. suffix 
If a configuration variable starts with numbers and has a character
that such as K/k/G/g/etc.. it would assume that it was a number
(expressed in Kb, Gb, etc..).

This PR checks that if the special characters are not the suffix,
that is, the variable does not end after those characters, then
the parsing will treat the whole thing as a string.

Resolves #3431

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-02 18:15:04 -06:00
Ivan Kozlovic
c4b5ca7cff Merge pull request #3433 from nats-io/js_offline_nodes 
[FIXED] JetStream: Some nodes may never be reported as offline
 2022-09-01 13:28:29 -06:00
Ivan Kozlovic
88ece75765 [FIXED] JetStream: Some nodes may never be reported as offline 
In some rare situations, it is possible that nodes are added
to the cluster but are not properly tracked and not shown as
offline when they exit the cluster.

Relates to #3258

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-09-01 12:48:12 -06:00
Ivan Kozlovic
ef2099df80 Merge pull request #3430 from mprimi/js-kv-benchmarks 
KeyValue Put/Get/Update benchmark
 2022-09-01 10:37:35 -06:00
Marco Primi
1e040a5569 KeyValue Put/Get/Update benchmark 2022-08-31 17:12:29 -07:00
Derek Collison
4b5e0a3f87 Merge pull request #3429 from nats-io/stream-overlap-subjects 
[FIXED] Do not allow overlap between multiple subjects for a stream.
 2022-08-31 16:19:27 -07:00
Ivan Kozlovic
ca54468f3d Merge pull request #3425 from mprimi/js-publish-and-consume-benchmarks 
Publish and consume JS benchmarks
 2022-08-31 17:12:06 -06:00
Ivan Kozlovic
cc22510669 Merge pull request #3428 from nats-io/fix_3420 
[FIXED] JetStream: expired accounts were counted toward limits
 2022-08-31 17:06:30 -06:00
Derek Collison
452e3c3955 Make sure update covered 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-31 16:05:32 -07:00
Derek Collison
b649ae8bc3 We detected overlap between different streams but not same stream with multiple subjects. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-31 15:51:39 -07:00
Ivan Kozlovic
c8af84d3d1 [FIXED] JetStream: expired accounts were counted toward limits 
Fix from @JulienVdG in PR #3421. Adding simply a test and make
sure that tests run.

Resolves #3420

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-08-31 16:40:11 -06:00
Marco Primi
2c3879585c JetStream publish and consume benchmarks 2022-08-31 14:52:45 -07:00
Marco Primi
e0821cfa3d Compose cluster URL without trailing comma 
Related to: https://github.com/nats-io/nats.go/issues/1056
 2022-08-31 14:52:45 -07:00
Marco Primi
f1883561ee Use testing.TB interface instead of *T 
Using interface allows reusing helper function in benchmarks
 2022-08-31 14:52:45 -07:00
Marco Primi
28d38c0213 Move bitset test utility 
From Chaos helpers (excluded from build by default) to JetStream helpers
 2022-08-31 14:52:45 -07:00
Derek Collison
62f91c1dd2 Bump to 2.9.0-RC.16 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-31 14:07:47 -07:00
Ivan Kozlovic
721410b23c Merge pull request #3427 from nats-io/gw_rsubs_changes 
[FIXED] JetStream: possible routing issues through gateways
 2022-08-31 14:52:13 -06:00
Ivan Kozlovic
8d1fb4bc92 [FIXED] JetStream: possible routing issues through gateways 
Internally jetstream may subscribe to some subject and then send
a request with a reply subject matching that subscription.
Due to interest propagation through a super cluster, it is possible
that the reply comes back to a node that is not yet aware of
the subscription interest which would cause the reply to be dropped.

Some code detects that the subscription is recent and "map" the
reply subject so that it can be routed back to the origin server.
However, this was done with the use of the connection object that
created the subscription, but at the time of the send, a different
internal "*client" object may be used which would then cause
the code to not be aware of the recent subscription and not do
the mapping.

This code was changed to scope at the account level instead of
connection.

A recent change in PR #3412 is no longer needed and was reverted
in favor of changes in this PR.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-08-31 14:18:28 -06:00
Ivan Kozlovic
fdbee9bdaa Merge pull request #3424 from nats-io/js_catchup_default_max 
Bump back the defaultMaxTotalCatchupOutBytes to 128MB
 2022-08-31 10:18:30 -06:00
Ivan Kozlovic
5573933034 Bump back the defaultMaxTotalCatchupOutBytes to 128MB 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-08-31 09:19:28 -06:00
Derek Collison
4b9db05a0c Merge pull request #3423 from nats-io/sc 
[FIXED] Subjects collide would not properly return false.
 2022-08-31 06:58:13 -07:00
Derek Collison
119f1492ec [FIXED] Subjects collide would not properly return false in some conditions. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-31 06:38:43 -07:00
Derek Collison
cb3b88d4e4 Bump to 2.9.0-RC.15 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-30 16:24:11 -07:00
Derek Collison
1eb1372686 Merge pull request #3419 from nats-io/migrate-v2 
Allow optional compression in raft and stream catchup, move improvements for streams and consumers
 2022-08-30 16:23:35 -07:00
Derek Collison
98bf861a7a Updates to stream and consumer move logic. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-30 16:11:35 -07:00
Derek Collison
56e177c329 Allow stream msgs to be compressed within the raft layer and during upper layer catchups. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-30 16:10:57 -07:00
Ivan Kozlovic
8b697db99e Merge pull request #3418 from nats-io/js_config_max_catchup 
[ADDED] JetStream: Ability to configure the per server max catchup bytes
 2022-08-30 15:06:19 -06:00
Ivan Kozlovic
ed4bb282f6 Rename config param to max_outstanding_catchup 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-08-30 14:51:34 -06:00
Ivan Kozlovic
9a6a2c31ee [ADDED] JetStream: Ability to configure the per server max catchup bytes 
The original value was hardcoded to 128MB and 32MB per stream. The
per-server limit is lowered to 32MB but is configurable with
a new configuration parameter:
```
jetstream {
   max_catchup: 8MB
}
```

The per-stream limit was also lowered from 32MB/128,000msgs to
8MB/32,000 messages.

Tests have shown no difference in performance for fast links.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-08-30 13:46:13 -06:00
Derek Collison
a9790aa0fa Merge pull request #3409 from nats-io/cc-secure 
[IMPROVED] Secure consumer create
 2022-08-30 09:48:06 -07:00
Derek Collison
aa94a0bc0f New consumer create that allows elevation of stream and consumer names, and optional filter subject to the request subject. 
Similar to changes in direct get allows proper security if needed for filter subject selection.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-08-30 09:29:38 -07:00