Commit Graph

5048 Commits

Author SHA1 Message Date
Ivan Kozlovic
d34b8fdd7d [FIXED] JetStream: data race on shutdown
Replaced use of eventsEnabled() with EventsEnabled() that will
check under server lock. Also found another reference when
creating templates.

Resolves #2588

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-30 11:17:12 -06:00
Derek Collison
c9eeab1d0d Merge pull request #2585 from nats-io/rollups
Rollup functionality.
2021-09-30 04:05:17 -07:00
Derek Collison
c062190b0a Rollup functionality.
Messages published with the rollup header will place the new message onto the stream and purge all others based on subject, or the complete stream.

Signed-off-by: Derek Collison <derek@nats.io>
2021-09-29 18:59:21 -07:00
Derek Collison
1338a167e3 Merge pull request #2584 from nats-io/sealed-stream
Allow streams to be sealed through a stream update.
2021-09-29 16:02:58 -07:00
Derek Collison
5fc2cc5754 Allow streams to be sealed through a stream update.
Sealed streams can not accept new messages, allow you to delete or purge messages, or have messages expire due to age.
Sealed stream can not be unsealed through an update.

Signed-off-by: Derek Collison <derek@nats.io>
2021-09-29 15:25:38 -07:00
R.I.Pienaar
38a853f0ff Merge pull request #2583 from ripienaar/fix_msg_get_audit
fixes the msg get audit event
2021-09-29 23:58:47 +02:00
R.I.Pienaar
98ef6cb03c fixes the msg get audit event
We resused msg variable for both the request
and later the data loaded from the stream.

The data thus replaces the request and the audit
had the data as both request and response

Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-09-29 17:36:38 +02:00
Matthias Hanel
377a46eedd Merge pull request #2580 from nats-io/hdr-ping
[fixed] missing support for header in some request handler
2021-09-28 17:41:15 -04:00
Matthias Hanel
9c01794f5f Merge pull request #2581 from nats-io/src-mirror-ln-3way
added unit test to test stream source/mirror cross different domains
2021-09-28 17:41:04 -04:00
Waldemar Quevedo
31680da399 Merge pull request #2582 from nats-io/go-mod
Update nats-io/jwt dependency
2021-09-28 14:11:27 -07:00
Waldemar Quevedo
b96f731f1a Update nats-io/jwt dependency
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-09-28 13:24:24 -07:00
Matthias Hanel
11bf8505cf added unit test to test stream source/mirror cross different domains
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-09-28 16:20:37 -04:00
Derek Collison
51a6224f91 Merge pull request #2579 from nats-io/mixed-coldboot
Adjust cluster size on cold start in mixed mode
2021-09-28 11:29:41 -07:00
Matthias Hanel
3379b3b612 [fixed] missing support for header in some request handler
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-09-28 14:28:03 -04:00
Derek Collison
de83307e8d Log when we adjust the peer set size
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-28 11:02:53 -07:00
Derek Collison
f4177bacbc Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-27 19:59:05 -07:00
Derek Collison
74e2034aed Only adjust downward if we have a total >= original estimate
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-27 18:39:37 -07:00
Derek Collison
8223275c44 On cold start in mixed mode if the js servers were not > non-js we could stall.
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-27 16:59:42 -07:00
Ivan Kozlovic
c91f0fec3f Merge pull request #2571 from nats-io/release_2_6_1_bis
Release v2.6.1
2021-09-23 18:08:46 -06:00
Ivan Kozlovic
6400c8cabf Release v2.6.1
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-23 17:47:47 -06:00
Ivan Kozlovic
812ba157ba Merge pull request #2568 from nats-io/js-conn-cnt
[FIXED] Internal connections were counted toward account's max connections (client or leaf)
2021-09-23 17:45:00 -06:00
Derek Collison
15fb253c7c Revert back to old subject, don't suppress updates on non client/leaf
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-23 16:07:35 -07:00
Derek Collison
3740a707f6 Do not count non client or leafnode connections for account limit reporting.
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-23 15:43:07 -07:00
Derek Collison
77eb639b2c Merge pull request #2569 from nats-io/catchup
Improve handling when exceeding account resources.
2021-09-23 14:48:20 -07:00
Derek Collison
7340dde408 Improve handling when exceeding account resources and trying to catch up streams, etc.
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-23 14:21:14 -07:00
Ivan Kozlovic
3c537824bc Merge pull request #2567 from nats-io/fix_flapper
Fix corrupt wal test that was flapping
2021-09-23 10:14:39 -06:00
Ivan Kozlovic
7b25755980 Adjust timing
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-23 09:56:42 -06:00
Matthias Hanel
6fe3939ca4 NO COMMIT, demonstrate JS conn count
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-09-23 11:53:34 -04:00
Ivan Kozlovic
23e8dc9902 Fix corrupt wal test that was flapping
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-23 09:36:46 -06:00
Ivan Kozlovic
7d389169d5 Update version to beta until ready to release
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-23 09:08:54 -06:00
Ivan Kozlovic
d58b2a106f Merge pull request #2563 from nats-io/mixed_enablement_js
[FIXED] Storage limit of 0, which means disabled, was not always enforced
2021-09-22 17:52:05 -06:00
Ivan Kozlovic
93dc39dcda Fixed other MQTT test that was setting JWT mem but not disk limits
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-22 17:24:33 -06:00
Ivan Kozlovic
a3be36fcd4 Moving 2 new tests to jetstream test file
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-22 17:02:29 -06:00
Ivan Kozlovic
b0d487fe68 Fix MQTT test that was not setting MaxStore
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-22 16:51:34 -06:00
Derek Collison
f6f5d6d4b2 Merge pull request #2564 from nats-io/max-consumers
Direct consumers used for mirroring should not be affected by max consumers limits
2021-09-22 15:29:28 -07:00
Derek Collison
944b90d4a3 Fix for no storage limits
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-22 15:28:43 -07:00
Derek Collison
ebb24006c2 Direct consumers used for mirroring should not be affected by max consumer limits
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-22 15:01:51 -07:00
Derek Collison
ed317bb60d Merge pull request #2565 from nats-io/bytes-pending
Make sure wp is > len(cache.buf)
2021-09-22 14:59:01 -07:00
Derek Collison
075e8c9070 Make sure wp is > len(cache.buf)
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-22 14:46:31 -07:00
Matthias Hanel
060beff99f NO COMMIT, unit test to show issue with mixed enablement of js storage
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-09-22 17:20:14 -04:00
Ivan Kozlovic
6c633013fb Merge pull request #2562 from nats-io/release_2_6_1
Release v2.6.1
2021-09-22 14:13:00 -06:00
Ivan Kozlovic
fd24c6feb0 Release v2.6.1
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-22 13:55:37 -06:00
Derek Collison
5f0a2b96f9 Merge pull request #2561 from nats-io/mirror-deadlock
[FIXED] Deadlock with stream mirrors
2021-09-22 11:21:32 -07:00
Derek Collison
eab45b404a Fix for deadlock with stream mirrors or sources where origin is interest or workqueue policy.
Signed-off-by: Derek Collison <derek@nats.io>
2021-09-22 10:59:02 -07:00
Ivan Kozlovic
3a4fd2bf24 Merge pull request #2557 from nats-io/release_2_6_0
Release v2.6.0
2021-09-21 16:59:23 -06:00
Ivan Kozlovic
f34156e411 Release v2.6.0
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-09-21 16:17:27 -06:00
Matthias Hanel
58596ce5b7 Merge pull request #2555 from nats-io/reserved_memory_usage
[added] value to JS stats showing memory used from accounts with reservations
2021-09-21 18:16:03 -04:00
Matthias Hanel
29a6367889 incorporating review comments.
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-09-21 17:13:53 -04:00
Matthias Hanel
9911b37b0c [added] value to JS stats showing memory used from accounts with reservations
[fixed] reservations accounting issue on reload introduced by:
commit: bfb726e8e9
clearResources appeared to have been a workaround and broke
reload for non global accounts

Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-09-21 16:35:24 -04:00
Derek Collison
29037a4f5c Merge pull request #2554 from nats-io/issue-2551
[FIXED] #2551
2021-09-21 09:15:23 -07:00