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
5,333 Commits 30 Branches 48 Tags
35e8c57f064dccc993d0883faa97e6d9c67bdd69
Commit Graph

3493 Commits

Author SHA1 Message Date
Derek Collison
35e8c57f06 Merge pull request #2814 from nats-io/neg_deleted 
If we detect negative deleted, adjust to 0.
 2022-01-24 11:52:58 -08:00
Ivan Kozlovic
dc3972304d Merge pull request #2791 from mattstep/mattstep/replication-lag-metrics 
[ADDED] Replication lag to stream monitoring
 2022-01-24 12:07:06 -07:00
Derek Collison
d07000cde0 If we detect negative deleted, adjust 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-24 10:52:46 -08:00
Matt Stephenson
59cc0f0015 Add source and mirror info to stream monitoring 2022-01-21 12:44:42 -08:00
Derek Collison
ecd0d8eaff Reset authSet state 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-21 11:03:19 -08:00
Derek Collison
ae43b24be4 Fixed #2810. Do not warn about password for internally generated no auth user when just system account assigned to non-default. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-21 10:09:10 -08:00
Derek Collison
dcadf6643a When no_auth_user is set, do not require a CONNECT proto. 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-21 09:41:45 -08:00
Ivan Kozlovic
7aba8a8e9e Bump version to v2.7.1-beta02 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-20 16:32:30 -07:00
Jaime Piña
c82b583d7a Fix race condition in HTTP monitoring shutdown (#2805) 2022-01-20 15:29:17 -08:00
Ivan Kozlovic
f6acc9d28b [FIXED] Possible deadlock 
This is due to a re-entrant RLock(). It works sometimes, but if there
is a go routine requesting the write lock, then the second RLock()
will not be granted which will lead to a deadlock.
In summary: one should never make re-entrant RLock calls.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-20 13:53:52 -07:00
Ivan Kozlovic
c76bf81267 Fixed goreleaser ldflags 
Since we moved to go modules, the path must include the `/v2`.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 19:02:41 -07:00
Ivan Kozlovic
f1d2f7c797 Release v2.7.0 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 17:11:02 -07:00
Ivan Kozlovic
70b1f5c950 Fix goreleaser script invocation - bump to rc2 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 16:58:19 -07:00
Ivan Kozlovic
59eef192cd Prepare for release v2.7.0, start with v2.7.0-rc1 
Since we have never released with goreleaser and GO111MODULE=on
and have removed vendor directory, we are going to push a
v2.7.0-rc1 tag. If the goreleaser process works fine and submit
the draft release correctly, we will not do an actual v2.7.0-rc1
release. Instead, we will follow up immediately with the v2.7.0
tag and the proper release.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 16:15:51 -07:00
Ivan Kozlovic
84f6cbb760 Pooling pubMsg and jsPubMsg objects 
This should help with GC pressure, however, it may have an effect
on performance (based on some benchmark). Calling sync.Pool.Get/Put
too often has a performance impact...

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:14:25 -07:00
Ivan Kozlovic
3ce22adb76 Fixed some tests 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:14:05 -07:00
Ivan Kozlovic
29c40c874c Adding logger for IPQueue 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:14:00 -07:00
Ivan Kozlovic
48fd559bfc Reworked RAFT's leader change channel 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:12:11 -07:00
Ivan Kozlovic
fc7a4047a5 Renamed variables, removing the "c" that indicated it was a channel 2022-01-13 13:11:05 -07:00
Ivan Kozlovic
62a07adeb9 Replaced catchup and stream restore channels 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:09:49 -07:00
Ivan Kozlovic
645a9a14b7 Replaced RAFT's stepdown channel 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:09:01 -07:00
Ivan Kozlovic
2ad95f7e52 Replaced RAFT's vote request and response channels 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:08:05 -07:00
Ivan Kozlovic
d74dba2df9 Replaced RAFT's append entry response channel 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:06:48 -07:00
Ivan Kozlovic
b5979294db Replaced RAFT's append entry channel 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:06:29 -07:00
Ivan Kozlovic
ceb06d6a13 Replaced RAFT's apply channel 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:06:10 -07:00
Ivan Kozlovic
05c033c46c Replaced stream's inbound list 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:05:51 -07:00
Ivan Kozlovic
23ebf9d2f8 Adapted jsOutQ 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:05:27 -07:00
Ivan Kozlovic
2ca025b33d Adapted system sendq 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:05:07 -07:00
Ivan Kozlovic
b44e9e01b6 Replaced MQTT's send queue 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:03:53 -07:00
Ivan Kozlovic
92e8997506 Replaced system event queue 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:03:33 -07:00
Ivan Kozlovic
c377a997e4 Replaced ackMsgQueue 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:03:26 -07:00
Ivan Kozlovic
a890c4692d Added intra-process queue to exchange objects instead of channels 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 13:03:20 -07:00
Derek Collison
7dc99c3840 Merge from main 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-13 10:01:33 -08:00
Ivan Kozlovic
c9c603b7a0 Merge pull request #2573 from julius-welink/implement-rate-limiting 
[ADDED] TLS connection rate limiter
 2022-01-13 10:35:19 -07:00
Derek Collison
6619e7f13d Merge branch 'main' into pull-consumer 2022-01-13 09:14:33 -08:00
Derek Collison
165895906b Merge pull request #2781 from nats-io/rebuild-deadlock 
When rebuilding the complete filestore state we need to do this in a go routine.
 2022-01-13 08:05:56 -08:00
Waldemar Quevedo
0885ba247f Merge pull request #2782 from nats-io/js-and-monitoring 
Start monitoring before JetStream during startup.
 2022-01-13 07:13:39 -08:00
Waldemar Quevedo
ce4e4b5d47 Start monitoring before JetStream 
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2022-01-12 21:38:22 -08:00
Matthias Hanel
3fa7adbc43 Merge pull request #2779 from nats-io/max-bytes 
[Adding] support for JS MaxBytesRequired
 2022-01-12 23:31:42 -05:00
Derek Collison
420a2ef514 When rebuilding the complete state need to do this in a go routine. 
We did this properly above but forgot this one.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-12 20:19:45 -08:00
Derek Collison
103f710479 Fixed consumer info num pending bug. 
Under load we could have a message committed to the underlying store when a consumer was being created and then it increase num pending again when the stream signals the consumers.
This fix just remembers the last seq of the state when we calculate sgap and test before adding in the stream code.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-12 20:03:26 -08:00
Ivan Kozlovic
d63bc726c9 Merge pull request #2780 from nats-io/raft_updates 
[IMPROVED] JetStream clustering with lots of streams/consumers
 2022-01-12 21:02:49 -07:00
Matthias Hanel
78bbcd791f [Adding] support for JS MaxBytesRequired 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2022-01-12 22:57:34 -05:00
Ivan Kozlovic
ffe50d8573 [IMPROVED] JetStream clustering with lots of streams/consumers 
Some operations could cause the route to block due to lock being
held during store operations. On macOS, having lots of streams/consumers
and restarting the cluster would cause lots of concurrent IO that
would cause lock to be held for too long, causing head-of-line
blocking in processing of messages from a route.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-12 20:37:00 -07:00
Derek Collison
43eff407b8 Add in explicit subscription for import responses when bound to a leafnode. 
When we want to track service import response interest across a leafnode we need to send sub and unsub for all response _R_ subjects versus using a wildcard.

Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-12 18:24:03 -08:00
John Hooks
0b77d51905 Remove switch 
Removes switch statement and uses map for finding correct multiple

Also uses ParseInt instead of Atoi for getting string integer.
 2022-01-12 21:07:07 -05:00
John Hooks
4aa6c62bbc Fix non used error 2022-01-12 18:03:24 -05:00
John Hooks
d956d6d398 Review 
Rename function
More easily read math
merged functions together
Changed from predefining error
Fix empty string issue
use same function for max mem store
 2022-01-12 17:55:57 -05:00
Derek Collison
32c3c9ecfb Track interest properly across accounts for pull consumers 
Signed-off-by: Derek Collison <derek@nats.io>
 2022-01-12 12:16:53 -08:00
John Hooks
12f8179fd8 Add parsing of string for sizes 
Checks the suffix of the string to create the size of the int64
 2022-01-11 22:13:20 -05:00