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
7,947 Commits 30 Branches 48 Tags
3f28de8e83291359f84fcbb0e0c6f7bd07e564bd
Commit Graph

5402 Commits

Author SHA1 Message Date
Neil Twigg
19397a5683 Don't set block profile rate 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-08-16 17:00:07 +01:00
Jean-Noël Moyne
0cc43acb84 Fix Nats-Stream-Source header parsing when using multi-filter transforms 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-15 19:22:09 -07:00
Jean-Noël Moyne
c2d3ef1021 Fix potential out of range for stream source transform update. 
Clean up un-needed if statement as it's ok to call NewSubjectTransform with an empty destination (ie no transformation) it will return nil

Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-15 16:35:19 -07:00
Waldemar Quevedo
740e5ddc37 Add some jitter to leafnode remotes reconnect 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-15 07:36:37 -07:00
Neil
8717b050e9 [IMPROVED] $SYS.REQ.SERVER.PING.PROFILEZ always honored (#4393) 2023-08-14 22:03:46 +01:00
Jean-Noël Moyne
61a0555336 Call SetBlockProfileRate even it the profiling port is not set 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-14 10:58:20 -07:00
R.I.Pienaar
1d916ef9c7 Adds a missing json encoding tag 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2023-08-14 17:41:02 +03:00
Jean-Noël Moyne
40b8aa434b Remove part of the test that expects an error since now you can always get the profilez through the system account request 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-13 18:00:08 -07:00
Jean-Noël Moyne
b839c53abc [ADDED] Full StreamSource (filters, transforms) functionality to stream mirror (#4354) 
- [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)

Follow up to #4276 extending to Mirror the full StreamSource
functionality.

---------

Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-12 15:17:48 -07:00
Jean-Noël Moyne
bb53b54810 Remove the gate on a profiling port being defined in the server config for the profilez request to return profiling data even if the server doesn't have a profiling port set. 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-12 14:48:38 -07:00
Neil Twigg
3c9c124b94 When checking replica count when updating retention, make sure stream assignment is set first 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-08-11 14:15:49 +01:00
Jean-Noël Moyne
fc41ab1a5a Adds LDM and KICK server $SYS requests 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-10 17:08:09 -07:00
Waldemar Quevedo
37d3220dfb test: fixes for TestLeafNodeSlowConsumer (#4388) 
It would fail sometimes locally otherwise...
```
=== RUN   TestLeafNodeSlowConsumer
    leafnode_test.go:7069: got: 0, expected: 1
--- FAIL: TestLeafNodeSlowConsumer (0.29s)
=== RUN   TestLeafNodeSlowConsumer
    leafnode_test.go:7069: got: 0, expected: 1
--- FAIL: TestLeafNodeSlowConsumer (0.28s)
=== RUN   TestLeafNodeSlowConsumer
--- PASS: TestLeafNodeSlowConsumer (0.28s)
=== RUN   TestLeafNodeSlowConsumer
    leafnode_test.go:7069: got: 0, expected: 1
--- FAIL: TestLeafNodeSlowConsumer (0.28s)
=== RUN   TestLeafNodeSlowConsumer
--- PASS: TestLeafNodeSlowConsumer (0.28s)
```
 2023-08-10 01:12:21 -07:00
Waldemar Quevedo
f16582e2a4 test: update TestWSTLSVerifyClientCert for go1.21 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-09 21:50:46 -07:00
Waldemar Quevedo
7c9ea91296 test: fix TestLeafNodeSlowConsumer flake 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-09 21:35:24 -07:00
Waldemar Quevedo
3cec8dc451 test: fix TestNoRaceJetStreamMemstoreWithLargeInteriorDeletes flake 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-09 13:33:48 -07:00
Waldemar Quevedo
af766b78ce test: bump timeout from TestFileStoreNewWriteIndexInfo to 3ms 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-09 11:16:44 -07:00
Waldemar Quevedo
4625234bba test: delay slightly between filestore test permutations 
This is to try to prevent test failing due to trying to access
the tempdir while it is being tore down.
(go issue: https://github.com/golang/go/issues/43547)

```
=== RUN   TestFileStoreMsgBlkFailOnKernelFaultLostDataReporting/AES-GCM-S2
    filestore_test.go:5195: ------------> 128
    testing.go:1225: TempDir RemoveAll cleanup: unlinkat ./TestFileStoreMsgBlkFailOnKernelFaultLostDataReportingAES-GCM-S23605508670/001/msgs: directory not empty
--- FAIL: TestFileStoreMsgBlkFailOnKernelFaultLostDataReporting (0.02s)
```

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-09 10:53:13 -07:00
Piotr Piotrowski
27dc50eb8f [ADDED] Filter Healthz results based on stream and consumer names, add 'details` param 
Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
 2023-08-09 16:44:45 +02:00
Waldemar Quevedo
8b7dfe7d74 monitoring: track slow consumers per connection type 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-09 05:57:42 -07:00
Neil Twigg
d7f76da597 Allow switching from limits-based to interest-based retention in stream update 
Signed-off-by: Neil Twigg <neil@nats.io>
 2023-08-09 11:46:49 +01:00
Neil
6eb77fd46b test: fix TestAccountImportCycle flake (#4381) 
Add extra flushes to make test more precise and try to avoid timeouts

```
=== RUN   TestAccountImportCycle
    accounts_test.go:3447: require no error, but got: nats: timeout
--- FAIL: TestAccountImportCycle (1.01s)
```
 2023-08-09 11:39:52 +01:00
Neil
617d69d6c7 Match --signal PIDs with globular-style expression. (#4370) 
When multiple instances are running on the machine a PID argument
suffixed with a '*' character will signal all matching PIDs.

Example: `nats-server --signal reload=*`

 - [ ] Link to issue, e.g. `Resolves #NNN`
 - [ ] Documentation added (if applicable)
 - [X] Tests added
 - [X] Branch rebased on top of current ~~main~~ dev
- [X] Changes squashed to a single commit (described
[here](http://gitready.com/advanced/2009/02/10/squashing-commits-with-rebase.html))
 - [ ] 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)
 2023-08-09 11:16:56 +01:00
Waldemar Quevedo
14a56e28dd test: fix TestAccountImportCycle flake 
add extra flushes to make test more precise

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-08 23:41:18 -07:00
Waldemar Quevedo
e68c411b74 test: fix TestMQTTTLSVerifyAndMap on Go 1.21 
reported error changed slightly in Go 1.21

```
=== RUN   TestMQTTTLSVerifyAndMap
=== RUN   TestMQTTTLSVerifyAndMap/no_filtering,_client_does_not_provide_cert
    mqtt_test.go:1033: Unexpected error: Error reading: remote error: tls: certificate required
--- FAIL: TestMQTTTLSVerifyAndMap (0.04s)
```

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-08 23:10:29 -07:00
Waldemar Quevedo
1492cf717f test: fix TestFileStoreNewWriteIndexInfo hanging 
t.Fatalf being called while holding a lock would
sometimes leave builds hanging.

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-08 16:41:15 -07:00
Waldemar Quevedo
0ffd455e32 test: update TestNoRaceJetStreamServiceImportAccountSwapIssue flake (#4376) 
Let pull consumer in test fetch messages for slightly longer instead of
at the same time as the producer, to avoid failing due to missing a few
messages:

```
=== RUN   TestNoRaceJetStreamServiceImportAccountSwapIssue
    norace_test.go:1194: Expected to receive 14982 msgs, only got 14981
--- FAIL: TestNoRaceJetStreamServiceImportAccountSwapIssue (3.03s)
```
 2023-08-08 02:01:44 -07:00
Waldemar Quevedo
b081f8c2ea test: update TestNoRaceJetStreamServiceImportAccountSwapIssue flake 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-08 01:07:19 -07:00
Tomasz Pietrek
54fe8cb14f Fix race in consumer create 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-08-08 09:16:44 +02:00
Waldemar Quevedo
2630e9b597 test: bump timeout from TestAccountReloadServiceImportPanic 
It can take slightly longer in a testing environment.

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-07 16:42:12 -07:00
Jason Volk
9c4ae764a1 Match --signal PIDs with globular-style expression. 
When multiple instances are running on the machine a PID argument suffixed with
a '*' character will signal all matching PIDs.

Example: `nats-server --signal reload=*`

Signed-off-by: Jason Volk <jason@zemos.net>
 2023-08-07 10:16:05 -07:00
Derek Collison
6ca7887992 [IMPROVED] Delete blocks performance (#4371) 
Track deleted with single avl.SeqSet dmap for now vs old method for
memory store.

For fileStore, we were trying to be too smart to save space at the
expense of encoding time, so revert back to simple version that is much
100x faster.
 
Size of encoding may be a bit bigger then we wanted, but we want to
prefer speed over size.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-07 09:18:48 -07:00
Waldemar Quevedo
abe0791313 Fixes to service system imports on reload also when using custom system account (#4372) 
Adds back the fix from #4369 and also fixes the export that was going
missing in dev branch when a custom system account was being used.
 2023-08-07 09:02:48 -07:00
Jean-Noël Moyne
2d5c5d68ce Adds a few tests to verify that addConsumerWithAction also works for named ephemeral consumers as well as for durables 
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
 2023-08-07 08:28:21 +02:00
Tomasz Pietrek
d105e68c96 Add consumer api action for create and update 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-08-07 08:28:21 +02:00
Waldemar Quevedo
6b9008c1f4 Fixes to service imports on reload 
Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-05 18:21:01 -07:00
Derek Collison
75e1171bdd No longer compacting multiple blocks, so remove test check 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-05 13:20:38 -07:00
Derek Collison
3b235059fa We were trying to be too smart to save space at the expense of encoding time for filestore. 
Revert back to very simple but way faster method. Sometimes 100x faster and only ~8% size increase.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-05 12:33:30 -07:00
Derek Collison
1f00d0e3f2 Track deleted with single avl.SeqSet dmap for now vs old method. 
Size of encoding may be a bit bigger then we wanted, but still way better then old method and very fast.

Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-05 12:32:29 -07:00
Waldemar Quevedo
eecb8af997 Remove reload fix from main 
This workaround will not work for v2.10 branch features

Signed-off-by: Waldemar Quevedo <wally@nats.io>
 2023-08-04 16:57:39 -07:00
Derek Collison
c0c9633024 Fix for flapping test 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-04 15:13:44 -07:00
Derek Collison
20532c28dd Merge branch 'main' into dev 2023-08-04 12:03:13 -07:00
Derek Collison
f2c7a9d37f Fix for flapping test 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-04 12:02:59 -07:00
Derek Collison
3c57adcfe5 Bump to 2.10.0-beta.49 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-04 10:16:09 -07:00
Derek Collison
8079495903 Merge branch 'main' into dev 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-04 10:15:35 -07:00
Byron Ruth
c1d1f11a18 Release v2.9.21 
Signed-off-by: Byron Ruth <byron@nats.io>
 2023-08-04 10:11:06 -04:00
Derek Collison
8c6055babc Bump to 2.9.21-RC.6 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-03 13:25:14 -07:00
Derek Collison
cbe85c826a Also reset clseq to avoid immediate sequence mismatch 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-03 12:40:17 -07:00
Derek Collison
d522f4656c Bump to 2.9.21-RC.5 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-03 11:17:51 -07:00
Derek Collison
081140ee67 When taking over make sure to sync and reset clfs for clustered streams. 
Signed-off-by: Derek Collison <derek@nats.io>
 2023-08-03 10:41:10 -07:00