gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity
4,046 Commits 30 Branches 48 Tags
cleaup-raftnode-goroutines
Commit Graph

4046 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
R.I.Pienaar
162fd77161 upgrade nightlies to go 1.16 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-02-28 20:03:10 +01:00
Derek Collison
8cfc56f8b0 Enable support for changing config on stream restore. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 10:01:01 -08:00
Derek Collison
b9e1a921ff Use internal wildcard inbox for stream and consumer info requests. 
More gateway friendly but suffers from no echo, so added new client based internal send.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 10:01:01 -08:00
Derek Collison
57a6599777 Test updates 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:19:45 -08:00
Derek Collison
ef4567f24a Changes for sources and mirrors improvements. 
Better handling of messages on restart from a WAL.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:18:48 -08:00
Derek Collison
9fc7561c40 Support updating sources via stream update. 
Tweaked internal consumers and flow logic for sources and mirrors.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:17:17 -08:00
Derek Collison
0d29b0761a Tweaked buffered channels, moved locks for snapshots. 
Also placed debug for inline processing of append entries.
This is for removal of that inline.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:16:04 -08:00
Derek Collison
09467bd9ae Prep for restore config override 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:15:38 -08:00
Derek Collison
f5cbd55b46 Fixed data corruption bug, optimized Compact(). 
Also trim fs.blks slice appropriately to avoid unbound growth.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:14:25 -08:00
Derek Collison
6a03ab9629 Inline flow in clustered mode was flaky, removed that path. 
Changed up accounting.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:11:59 -08:00
Derek Collison
7c67a9c5cc Update Go client 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 05:11:01 -08:00
Matthias Hanel
51550e242a Merge pull request #1944 from nats-io/expire-duration 
changing NEXT expires field from time to duration in nanoseconds
 2021-02-27 14:03:44 -05:00
Matthias Hanel
c73d3b21eb changing NEXT expires field from time to duration in nanoseconds 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-02-26 20:45:44 -05:00
Derek Collison
48d9e1cdb0 Bump Version 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-26 07:53:48 -08:00
R.I.Pienaar
89f6bdbe09 Merge pull request #1941 from ripienaar/oos_advisory 
extend the out of space advisory
 2021-02-26 16:53:07 +01:00
Derek Collison
1068529575 Merge pull request #1942 from nats-io/mirrors 
Allow sources and mirrors to not be pre-defined.
 2021-02-26 08:48:07 -07:00
Derek Collison
7c670e4eae Allow sources and mirrors to not be pre-defined. 
Will keep trying to establish contact.

Fixed bug where double source headers for sourced messages were causing issues.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-26 07:32:29 -08:00
R.I.Pienaar
a4817bd7b6 extend the out of space advisory 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-02-26 11:10:05 +01:00
Derek Collison
1f43c8b718 Bump version 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 20:15:41 -08:00
Derek Collison
c6672260af Merge pull request #1937 from nats-io/wio 
[FIXED] Bug where followers would not snapshot/compact WAL.
 2021-02-25 21:14:52 -07:00
Derek Collison
69ffff2278 Skip test for now 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 20:02:06 -08:00
Derek Collison
98f98e214b Properly support memory based WALs 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 19:49:54 -08:00
Derek Collison
7ea5a8a64b Reverse the flag for fip 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 19:02:58 -08:00
Derek Collison
0f69e48511 Bug check err, check for out of space on catchup 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 18:25:16 -08:00
Derek Collison
e5c8774172 Handle out of space situations, general stability enhancements 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 17:54:29 -08:00
Derek Collison
b13ef6b9ec Track write errors. Fixed a few bugs. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 17:53:20 -08:00
Derek Collison
44b08c538a Pass deliver, don't remap 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 17:42:03 -08:00
Derek Collison
752f67acee Explicit on async and sync settings 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 17:08:14 -08:00
Derek Collison
a9ab41f13b Fix lock bug, capture write errors and report better 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 15:01:47 -08:00
R.I.Pienaar
504652a16f Merge pull request #1940 from ripienaar/always_store_filter 
always store the filter subject
 2021-02-25 20:20:10 +01:00
R.I.Pienaar
45a42864f6 always store the filter subject 
This avoids a situation where a consumer asks for
ORDERS.new today on a stream of ORDERS.new but later
someone makes the same stream ORDERS.* and the new
consumer would then get messages for other purposes
as well

Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-02-25 18:29:21 +01:00
R.I.Pienaar
b4c5125ae5 Merge pull request #1938 from ripienaar/replication_info 
ensure sources and mirror info is in stream list
 2021-02-25 15:32:21 +01:00
Derek Collison
7ef3e5b629 Remove slow advisory checks 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 04:17:56 -08:00
Derek Collison
a862cc75cc Suppress raft campaigns on restart. Extend election timeout interval. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-25 04:14:14 -08:00
R.I.Pienaar
157d92daf7 ensure sources and mirror info is in clustered stream list 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-02-25 12:57:41 +01:00
Derek Collison
c7d203db6d Fixed bug where followers WAL would not snapshot/compact. 
Tweaked write and sync params.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 20:51:28 -08:00
Derek Collison
b7a5587b0c spelling 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 20:50:00 -08:00
Derek Collison
73ba2d0b2f File writes to term and vote and peerstate were in the direct route path and could cause delays. 
This moves the actual writes to a separate Go routine and also allows multiple writes to
be compressed into one write under load. We only want latest.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 20:47:31 -08:00
Derek Collison
2d24571e17 Change default sync to 60s 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 20:44:05 -08:00
Derek Collison
cc038a6d95 Merge pull request #1936 from nats-io/xacc2 
Properly handle local deliver subjects
 2021-02-24 21:25:23 -07:00
Derek Collison
57403b1903 When pulling consumer messages if the consumer and the client were on the same server we needed to process local deliver subject. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 19:28:46 -08:00
Derek Collison
954aea16f6 Merge pull request #1935 from nats-io/xacc 
Cross account JetStream pull consumers.
 2021-02-24 18:52:28 -07:00
Derek Collison
3def02a459 check for '\n' at beginning og key 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 17:46:30 -08:00
Derek Collison
75fbcffedb Make sure it's the exact key 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 14:56:44 -08:00
Derek Collison
36a2cbeff7 Cross account pull consumers would not work correctly due to reply subject rewrite. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 13:33:24 -08:00
R.I.Pienaar
15fa5e21b8 Merge pull request #1934 from ripienaar/nightly_nats_version 
add version strings to the nightly builds of nats cli
 2021-02-24 20:58:33 +01:00
R.I.Pienaar
693f9959a2 add version strings to the nightly builds of nats cli 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-02-24 20:12:47 +01:00
Derek Collison
338e017dbe Merge pull request #1933 from nats-io/stable 
General stability improvements.
 2021-02-24 10:26:32 -07:00
Derek Collison
23d7725104 Removed this one due to slow timing now 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 09:16:50 -08:00
Derek Collison
84321f6697 These are slower so need to wait longer 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-24 08:55:58 -08:00