gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-15 18:50:41 -07:00
Code Issues Packages Projects Releases Wiki Activity
7,323 Commits 30 Branches 48 Tags
7993547beef8ab4dda6e2ebc2aeef58350d1210d
Commit Graph

4892 Commits

Author SHA1 Message Date
Caleb Lloyd
7993547bee Adjust in-process server info tls_required to tls_available 
Signed-off-by: Caleb Lloyd <caleb@synadia.com>
 2023-07-20 10:44:03 +01:00
Neil Twigg
ed9fafc796 Don't require TLS for in-process connection 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-20 10:43:58 +01:00
Derek Collison
244dda809c Fix bug that would race around check for last sequence per subject 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-07-18 11:29:59 -07:00
Derek Collison
360f807cef Moved to end for merge with other branches, minor changes 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-07-18 11:29:26 -07:00
Byron Ruth
e7bf1b3132 Add test case for concurrent expected last subject sequence 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-07-18 11:10:51 -04:00
Waldemar Quevedo
c1750b8a54 De-flake a few tests (#4311) 
This should hopefully make a small handful of tests less flakey.

Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 09:57:23 -07:00
Neil Twigg
2527e11304 Increase threshold in TestNoRaceJetStreamSlowFilteredInititalPendingAndFirstMsg 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 17:05:26 +01:00
Neil Twigg
6cdb0c7838 Wait for current in TestJetStreamClusterStreamUpdateSyncBug so in-flight state changes aren't lost 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 17:03:21 +01:00
Neil Twigg
abb47c9554 Only send one message in TestJetStreamRedeliverCount to prevent out-of-order redeliveries 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 16:56:01 +01:00
Neil Twigg
144abc0dd9 Make TestJetStreamAccountImportJSAdvisoriesAsService insensitive to event order 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 16:51:51 +01:00
Neil Twigg
b58204cff7 Use checkFor in TestJetStreamMsgHeaders 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 16:44:24 +01:00
Neil Twigg
979b265e26 Tweak timing in TestJetStreamClusterDeleteConsumerWhileServerDown 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 16:44:15 +01:00
Neil Twigg
81dd129043 Move assigned ports out of ephemeral range 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 15:08:17 +01:00
Neil Twigg
586717a3c0 Remap ports in leaf node tests to hopefully reduce flakes 
Multiple tests were using the same port numbers and it seems that the
NATS Servers were not always shutting down quickly enough, resulting
in `listen tcp 127.0.0.1:50554: bind: address already in use` failures.

Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-14 13:49:15 +01:00
Byron Ruth
63864490a5 Bump v2.9.21-beta 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-07-13 16:04:11 -04:00
Byron Ruth
b055f675ba Release v2.9.20 2023-07-13 15:29:30 -04:00
Derek Collison
1f39d744dd Only discard messages from MQTT QoS0 from internal jetstream clients if really a QoS1 jetstream publish. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-07-12 16:00:59 -07:00
Derek Collison
0c8552cd34 Evaluate service imports when publishing advisories (#4302) 
This should fix #4275 by allowing advisories to be copied into other
accounts via service imports.

Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-12 12:24:00 -07:00
Neil Twigg
1434ee7da8 More specific check for service imports vs any internal sub 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-12 19:52:31 +01:00
Neil Twigg
fbbbe28278 Evaluate service imports when publishing advisories 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-07-12 18:18:57 +01:00
Piotr Piotrowski
e3b132ae34 Test for gathering JS advisories from multiple accounts on a single account 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-07-12 13:26:18 +01:00
Derek Collison
9e9a9a082b When restoring a filestore with no key generator but it was encrypted, fail to restore. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-07-11 16:27:50 -07:00
Derek Collison
5390272074 Bump to 2.9.20-beta 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-07-11 14:29:17 -07:00
Derek Collison
353d543c16 When a queue subscriber was updated multiple times over a leafnode connection we added in more shadow subscriptions which could become zombies when the connection went away. 
In a case where a leafnode server had multiple queue subscribers on the same queue group, the hub server would add in multiple shadow subs. These subs would not be properly cleaned up and could lead to stale connections being associated with them.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-07-10 21:03:47 -07:00
Derek Collison
eb2aa352ec Updated Leafnode Test (#4283) 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-30 11:06:11 -07:00
Derek Collison
b207984a84 Made cloud clusters 5 nodes each 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-30 10:12:39 -07:00
Neil Twigg
0d1c666071 Add TestRouteNoLeakOnSlowConsumer and TestRouteNoLeakOnAuthTimeout 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-06-30 13:11:42 +01:00
Derek Collison
e31bf5c66d Added reverse flow to the mc leafnode test 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-29 16:10:31 -07:00
Derek Collison
a2b9ee9123 Shorten stream size for travis 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-28 15:56:41 -07:00
Derek Collison
1bb1a3cae1 Do not health check streams that are actively being restored. 
Could leave them in a bad state.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-28 15:27:45 -07:00
Derek Collison
9805101953 Use an account protected method to check for service imports to avoid data race when reloading accounts. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-27 19:52:43 -07:00
Derek Collison
855e1bb14e Allow more tolerance for travis 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-23 14:24:00 -07:00
Derek Collison
2b2e22ed52 When creating a consumer on a stream with a very large number of msg blks, calculating numPending could be slow. 
This aims to optimize a bit, more work to be done on streams with a very large (> 200k) number of msg blks.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-23 14:11:56 -07:00
Todd Beets
f854e95c11 Cert Store (aka wincert) 2023-06-22 12:25:54 -07:00
Derek Collison
031535b89d Add object store benchmark (#4220) 
- [ ] Link to issue, e.g. `Resolves #NNN`
 - [ ] Documentation added (if applicable)
 - [x] Tests added
- [x] Branch rebased on top of current main (`git pull --rebase origin
main`)
- [x] Changes squashed to a single commit (described
[here](http://gitready.com/advanced/2009/02/10/squashing-commits-with-rebase.html))
 - [x] Build is green in Travis CI
- [x] You have certified that the contribution is your original work and
that you license the work to the project under the [Apache 2
license](https://github.com/nats-io/nats-server/blob/main/LICENSE)

### Changes proposed in this pull request:
 - New benchmark for NATS JetStream Object Store
 2023-06-21 14:36:35 -07:00
reubenninan
13e09f2db4 Add benchmarks for object store 
Signed-off-by: reubenninan <reuben@nats.io>
 2023-06-21 16:05:30 -04:00
Neil Twigg
cf715845d1 Additional check for TLS required in WebSocket INFO 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-06-21 19:06:49 +01:00
Byron Ruth
9592b760b9 Release v2.9.19 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-06-20 10:55:31 -04:00
Neil Twigg
afdc2478ca WebSocket-specific INFO 
This fixes #4252 by ensuring that `tls_available`, `tls_required`, `host` and `port`
are populated based on the WebSocket listener rather than standard listeners.

Signed-off-by: Neil Twigg <neil@nats.io>
 2023-06-20 11:47:09 +01:00
Neil Twigg
e879a9fa0c Test MaxMsgs and MaxMsgsPer in combination 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-06-19 09:45:17 +01:00
Derek Collison
e8094c9f33 Make utility funcs helpers 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-16 12:07:21 -07:00
Derek Collison
b3f913237c Added in another DQ test across leafnodes. 
This test has multiple leafnode connections to different accounts and to a shared account to make sure behavior is correct.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-16 11:54:09 -07:00
Derek Collison
087a28a13e When creating replicated mirrors where the source stream had a very large starting sequence number, the server would use excessive CPU and Memory. 
This is due to the mirroring functionality trying to skip messages when it detects a gap. In a replicated stream this puts excessive stress on the raft system.
This step is not needed at all if the mirror stream has no messages, we can simply jump ahead.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-15 17:20:15 -07:00
Byron Ruth
bbf24a6d98 Bump v2.9.19-beta.1 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-06-13 15:48:05 -04:00
Byron Ruth
af805b57a4 Release v2.9.18 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-06-13 15:19:20 -04:00
Derek Collison
1d00ea4fa0 Bump to 2.9.18-beta.3 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-11 13:11:32 -07:00
Derek Collison
11963e51fe Optimize statsz locking and only send if we know we have external interest. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-10 20:25:05 -07:00
Derek Collison
aae218fe77 [IMPROVED] Only enable JetStream account updates in clustered mode. (#4233) 
If we know we are in stand alone mode we do not need to run the updates
for JetStream account resources updates.

Signed-off-by: Derek Collison <derek@nats.io>

Resolves #4227 (Partial)
 2023-06-10 17:03:11 -07:00
Derek Collison
a5de25f213 Only enable JetStream account updates in clustered mode. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-10 15:21:55 -07:00
Derek Collison
f81bc80676 Improve last msg lookup (KV Get) when subject is a literal subject. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-06-10 13:16:13 -07:00