gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-15 10:40:41 -07:00
Code Issues Packages Projects Releases Wiki Activity
5,927 Commits 30 Branches 48 Tags
8a94e14fe71703cb8a7ef5d7c2cec00fb68040db
Commit Graph

5927 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Derek Collison
8a94e14fe7 Bump to 2.9.0-beta.1 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-29 15:42:11 -07:00
Ivan Kozlovic
3d3b854d72 Merge pull request #3229 from nats-io/pull_inactive_threshold 
[FIXED] Pull consumer may be incorrectly removed after InactiveThreshold
 2022-06-29 16:40:42 -06:00
Derek Collison
4a94a172c4 Merge pull request #3227 from nats-io/filtered_mirrors 
Allow filtered stream mirrors
 2022-06-29 15:39:07 -07:00
Matthias Hanel
6bd14e1b7a removed commented out code (#3228) 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-06-29 20:31:12 +02:00
Matthias Hanel
6e52608936 [added] support for jwt account option DisallowBearer (#3127) 
* [added] support for jwt account option DisallowBearer

change 3 out of 3. Fixes #3084
corresponds to:
https://github.com/nats-io/jwt/pull/177
https://github.com/nats-io/nsc/pull/495

update jwt library to 2.3.0

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-06-29 18:19:14 +02:00
Ivan Kozlovic
c519df7e0d [FIXED] Pull consumer may be incorrectly removed after InactiveThreshold 
When creating a pull consumer with InactiveThreshold set, if the
application is doing pull requests with "no_wait" at regular interval
(lower than InactiveThreshold), the JS consumer should be considered
active and not deleted.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-06-29 10:15:09 -06:00
Derek Collison
a77d5941ef Allow filtered stream mirrors 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-29 08:12:38 -07:00
Derek Collison
b0580cdfc2 Fix some spellings 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-28 18:45:33 -07:00
Derek Collison
88d5062fc9 Merge pull request #3225 from nats-io/rework_starup_complete_check 
Rework startupComplete gate from PR #2360
 2022-06-28 17:44:28 -07:00
Ivan Kozlovic
f8b16f90be Tweak MQTT test 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-06-28 18:00:25 -06:00
Derek Collison
727cd0abae Merge pull request #3224 from nats-io/maxprocs 
AutoMaxProcs would default log output, this suppresses the logging.
 2022-06-28 16:43:18 -07:00
Ivan Kozlovic
5ed212ce04 Rework startupComplete gate from PR #2360 
The "InProcess" change make readyForConnections() possibly return
much faster than it used to, which could cause tests to fail.

Restore the original behavior, but in case of DontListen option
wait on the startupComplete gate.

Also fixed some missing checks for leafnode connections.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-06-28 17:36:39 -06:00
Derek Collison
c2de707ed6 AutoMaxProcs would default log output, this suppresses the logging. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-28 16:35:30 -07:00
Matthias Hanel
dff1a33693 [Fixed] race on unlocked cfg access (#3223) 
write originated in updateWithAdvisory while holding the lock

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-06-29 00:05:00 +02:00
Derek Collison
10e1d055a8 Merge pull request #3218 from 1995parham/main 
Add automaxprocs package
 2022-06-28 13:27:51 -07:00
Ivan Kozlovic
cb406edfcd Merge pull request #2360 from neilalexander/neilalexander/inprocessconn 
[ADDED] In-process connections
 2022-06-28 11:47:01 -06:00
Neil Alexander
558293e096 Fix the lock 2022-06-28 18:05:57 +01:00
Derek Collison
abc5905aa9 Merge pull request #3221 from nats-io/direct 
Made direct get from a stream part of the $JS.API hierarchy vs separate.
 2022-06-28 09:59:44 -07:00
Matthias Hanel
aba1da090b [ADD] account specific in/out msgs/bytes stats to CONNS (#3187) 
* [ADD] account specific in/out msgs/bytes stats to CONNS

This subject $SYS.ACCOUNT.%s.SERVER.CONNS will now respond with account
specific datastats for Received and sent messages as well as number of slow
consumers for the account.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-06-28 18:59:29 +02:00
Matthias Hanel
aabaf6f106 [fixed] reload related races (#3222) 
account.rm had races caused by reload copying rm from one account to
another

mset.store was used outsisde the lock

in rare cases the stasz message was not received in time.
Trigger automatically now

sometimes a statsz message received before reload cause issues.
try receiving a second time

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-06-28 18:36:13 +02:00
Neil Alexander
cedf08a1b7 Commit properly 2022-06-28 17:03:42 +01:00
Neil Alexander
ff696f00d8 Remainder of time after waiting for startupComplete, add waitgroup done call after createClient 2022-06-28 17:03:42 +01:00
Neil Alexander
5b04c49df9 Re-add startupComplete channel, make readyForConnections wait for it 2022-06-28 17:03:42 +01:00
Neil Alexander
9190feb05f Review comments @kozlovic 2022-06-28 17:03:40 +01:00
Neil Alexander
90d7e007c0 Update comments (re. review) 2022-06-28 17:02:47 +01:00
Neil Alexander
e9abc5801e Add InProcessConn, DontListen 2022-06-28 17:02:47 +01:00
Derek Collison
b8ef9b19a0 Made direct get from a stream part of the $JS.API hierarchy vs separate. 
Also for direct get and for pull requests, if we are not on a client connection check how long we have been away from the readloop.
If need be execute in a separate go routine.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-28 08:53:48 -07:00
Derek Collison
b0c4ec69ab Merge pull request #3216 from nats-io/update_consumer_filtered_subj 
Allow consumer filter subjects to be updated
 2022-06-28 08:42:08 -07:00
Parham Alvani
253ff6b517 chore: go mod tidy 2022-06-28 07:39:10 +04:30
Matthias Hanel
3421c49310 [Add] ability for operator to move streams (#3217) 
Also added:
ability to reload tags
special tag (!jetstream) to remove peer from peer placement
$JS.API.SERVER.STREAM.MOVE subject to initiate move away from a server

This changes a detail about regular stream move as well.
Before differing cluster names where used to start/stop a transfer.
Now only the peer list and it's size relative to configured replica matter.
Once a transfer is considered completed, excess peers will be dropped
from the beginning of the list.
This allows transfers within the cluster as well.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-06-28 02:36:32 +02:00
Derek Collison
3e87867a5e Merge pull request #3220 from nats-io/ci_json 
Default to essential ClientInfo for JetStream
 2022-06-27 16:30:38 -07:00
Derek Collison
e02016db26 Fix race 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-27 16:05:03 -07:00
Derek Collison
92cd7821de Convert server mutex to RW. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-27 16:05:03 -07:00
Derek Collison
830d659aec Do not default to sharing all client info for JetStream, only server and cluster info. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-26 07:11:02 -07:00
Parham Alvani
baf0506b78 feat: add automaxprocs 2022-06-25 19:59:04 +04:30
Derek Collison
9154fca7f1 Allow consumer filter subjects to be updated 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-24 12:38:01 -07:00
Derek Collison
67a182f98e Merge pull request #3214 from nats-io/go_1.18 
Go 1.18
 2022-06-24 11:22:45 -07:00
Derek Collison
a7bb479339 For older versions just check we did not break build step 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-24 10:54:02 -07:00
Derek Collison
4de1766f40 Fix TLS tests and allow older test certs for now 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-24 09:43:42 -07:00
Derek Collison
cc197771ec Allow compile and staticheck to pass. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-24 09:17:12 -07:00
Derek Collison
6b6a2202c7 Bump CI to Go 1.18 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-24 08:45:55 -07:00
Derek Collison
4d6b562450 Bump version to 2.8.5-beta.6 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-21 09:12:22 -07:00
Derek Collison
314abd6028 Merge pull request #3205 from nats-io/issue_3199 
[FIXED] Path separators in consumer or stream names prevented restoring a stream
 2022-06-21 09:04:44 -07:00
Derek Collison
7a0c63af55 Merge pull request #3204 from nats-io/issue_1921 
[FIXED] Allow users directives for leafnodes to not block reloads.
 2022-06-21 09:03:07 -07:00
Derek Collison
b4238259b3 Change test to not have path separators 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-20 12:16:46 -07:00
Derek Collison
1ade8fc881 When stream or consumer names contained path separators it prevented backup and restore. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-20 11:59:18 -07:00
Derek Collison
37f73ab229 Allow users directives for leafnodes to not block reloads. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-20 10:39:37 -07:00
Derek Collison
b108a84007 Merge pull request #3194 from nats-io/stream_placement 
[IMPROVED] Distributed placement of streams in a cluster
 2022-06-16 10:16:31 -07:00
Derek Collison
60b52b84c3 If no max bytes set do better randomization of placement. 
If the stream is replicated take into consideration number of ha assets on the server already.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-15 17:12:45 -07:00
Derek Collison
bcffdb954f Bump version to 2.8.5-beta.5 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-06-15 08:09:01 -07:00