gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity
5,325 Commits 30 Branches 48 Tags
7aba8a8e9ee7f44302c1965d61e11e2491c5a43c
Commit Graph

5325 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
4d3b3da39f Merge pull request #2803 from nats-io/fix_acc_deadlock 
[FIXED] Possible deadlock
 2022-01-20 15:57:47 -07: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
297b44394f Merge pull request #2790 from nats-io/fix_goreleaser_config 
Fixed goreleaser ldflags
 2022-01-13 20:11:04 -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
bb87a650ac Merge pull request #2789 from nats-io/release_v2_7_0 
Release v2.7.0
 2022-01-13 17:13:55 -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
f268aad00b Merge pull request #2787 from nats-io/release_2_7_0 
Prepare for release v2.7.0, start with v2.7.0-rc1
 2022-01-13 16:28:28 -07:00
Ivan Kozlovic
2ba6d97dc1 Update deps 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 16:17:46 -07:00
Ivan Kozlovic
5f166d5c5f Removed vendor directory 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2022-01-13 16:17:46 -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
56d5a04efd Merge pull request #2786 from nats-io/remove-roadmap 
Remove Roadmap
 2022-01-13 14:42:27 -07:00
Colin Sullivan
28a027a69c add roadmap link [ci skip] 
Signed-off-by: Colin Sullivan <colin@synadia.com>
 2022-01-13 14:38:25 -07:00
Ivan Kozlovic
0d7088966a Merge pull request #2775 from nats-io/replace_chan_with_queue 
Replace use of go channels with queues
 2022-01-13 14:05:45 -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
Colin Sullivan
619b157f98 remove roadmap 
Signed-off-by: Colin Sullivan <colin@synadia.com>
 2022-01-13 12:33:27 -07:00
Derek Collison
de5372efcc Merge pull request #2776 from nats-io/pull-consumer 
Pull Consumer Updates
 2022-01-13 10:26:40 -08: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
a7554bd5dd Merge pull request #2777 from hooksie1/2754 
[ADDED] Ability to express the max_file_store and max_memory_store as a string (100M, etc..)
 2022-01-12 20:41:38 -07: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