Commit Graph

3826 Commits

Author SHA1 Message Date
Ivan Kozlovic
2bd7a4d32e Merge pull request #1926 from nats-io/mqtt_clustering
MQTT clustering
2021-02-19 11:45:19 -07:00
Matthias Hanel
efcd2acd0b Merge pull request #1925 from nats-io/ln-wrong-subject
[fixed] LeafNode sending message using stream's import subject.

This fixes #1766
2021-02-19 13:36:07 -05:00
Ivan Kozlovic
7526c76703 Changes to setHeader
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-02-19 10:46:14 -07:00
Ivan Kozlovic
61bd1b8d86 MQTT clustering
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-02-19 08:50:00 -07:00
Ivan Kozlovic
eafc6b7a25 [fixed] LeafNode sending message using stream's import subject.
A publish on "a" becomes an LMSG on ">" which
is the stream import's subject. The subscriber on "a" on the other
side did not receive the message.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-02-19 00:11:41 -05:00
Derek Collison
e81b208591 Change for client update in api requests
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 20:05:53 -08:00
Derek Collison
cc1edcead7 Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 19:22:46 -08:00
Derek Collison
882ead6504 Merge pull request #1924 from nats-io/sc_interest
Cross cluster consumer interest.
2021-02-18 20:13:19 -07:00
Derek Collison
9de18dfefe Removed unused function
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 18:35:44 -08:00
Derek Collison
afea79610a Consumer interest was not properly handled cross cluster.
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 18:29:59 -08:00
Derek Collison
048011d7f1 Split vote improvements
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 18:29:18 -08:00
Matthias Hanel
1b1ffa7401 Merge pull request #1923 from nats-io/processMsgResults
[fixed] out of range issue in processMsgResults during subject rewrite
2021-02-18 19:27:14 -05:00
Matthias Hanel
b410026319 [fixed] out of range issue in processMsgResults during subject rewrite
Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-02-18 16:16:41 -05:00
Derek Collison
d58e68051a Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 08:52:52 -08:00
Derek Collison
136c18d052 Merge pull request #1922 from nats-io/s2
various bug fixes, wal/snapshot stability
2021-02-18 09:52:17 -07:00
Derek Collison
89fe3b05df various bug fixes, wal/snapshot stability
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-18 08:41:09 -08:00
Derek Collison
700726c75b Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-17 20:14:32 -08:00
Derek Collison
d68753c037 Merge pull request #1920 from nats-io/stable
General stability improvements.
2021-02-17 21:10:31 -07:00
Derek Collison
e21c7097f3 General stability improvements.
Original thought to move to memory based WALs was ill-advised and caused issues with stability around restarts.
Returned to file based but with async flush for the WAL itself.
Also the raft inline catchup has been improved.

Signed-off-by: Derek Collison <derek@nats.io>
2021-02-17 19:56:16 -08:00
Derek Collison
2c6381cc06 Merge pull request #1918 from nats-io/bump
Some stability improvements to raft lib and catchup stream processing.
2021-02-16 21:50:28 -07:00
Derek Collison
765b9ad57a Some stability improvements to raft lib and catchup stream processing.
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-16 20:30:12 -08:00
Derek Collison
73d819c433 Merge pull request #1916 from nats-io/better_restore
Better restore logic
2021-02-16 17:19:02 -07:00
Derek Collison
ddc4cc79d2 Make sure to not process AR when no longer leader
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-16 15:58:46 -08:00
Derek Collison
eecec2aed1 Increase due to sendq
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-16 14:17:46 -08:00
Derek Collison
ddc800174f Stabilize catchups and snapshot logic
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-16 13:30:02 -08:00
Derek Collison
0dcb006968 Handle AppendEntry reponse inline, lower outstanding on catchup to stabilize
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-16 13:24:09 -08:00
Derek Collison
30cc739797 Increase internal sendq due to JSC
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-16 13:19:13 -08:00
Ivan Kozlovic
84ae705ccf Merge pull request #1915 from nats-io/fix_1912
[FIXED] Gateway's implicit connection not using global user/pass
2021-02-16 11:05:25 -07:00
Ivan Kozlovic
8598de6dbe [FIXED] Gateway's implicit connection not using global user/pass
If a gateway is configured with an authorization block containing
username and password and accepts an unknown Gateway connection,
when initiating the outbound connection, it should use the
gateway authorization's user/pass information.

Resolves #1912

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-02-16 10:06:06 -07:00
R.I.Pienaar
546f7a9816 Merge pull request #1914 from ripienaar/nightly_fix
revert to previous checkout version
2021-02-16 15:29:39 +01:00
R.I.Pienaar
3521d4c463 revert to previous checkout version
Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-02-16 11:50:13 +01:00
R.I.Pienaar
50e9a8b609 Merge pull request #1911 from ripienaar/trigger_nightly
enable manual triggers of nightly builds
2021-02-15 21:21:54 +01:00
R.I.Pienaar
1c27acb846 enable manual triggers of nightly builds
Signed-off-by: R.I.Pienaar <rip@devco.net>
2021-02-15 21:17:11 +01:00
Derek Collison
7cc49f8c62 Use system account when nil
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-15 08:23:16 -08:00
Derek Collison
82de5a3cf8 Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-14 19:07:12 -08:00
Derek Collison
444c8917f4 Merge pull request #1909 from nats-io/restore
Restoration of streams would possibly block route and client connections.
2021-02-14 20:06:18 -07:00
Derek Collison
4c6e33c9c6 Restoration of streams would possibly block route and client connections.
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-14 18:43:40 -08:00
Derek Collison
fcb9be5f6c Skip perf tests
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-13 14:37:15 -08:00
Derek Collison
ddae2cefaa Merge pull request #1908 from nats-io/offbyone
Set pindex to wrong setting on snapshot restore with no WAL
2021-02-13 08:51:21 -07:00
Derek Collison
f0cfc187d2 Set pindex to wrong setting on snapshot restore with no WAL
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-13 06:50:50 -08:00
Derek Collison
6f33659791 Bumped Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-12 20:11:34 -08:00
Derek Collison
f9ea8f264a Merge pull request #1907 from nats-io/jsimports
Changes needed to properly support multi-layer service imports
2021-02-12 21:10:46 -07:00
Derek Collison
4759560e29 Fixed raft bug on catchup logic with external snapshots
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-12 19:58:02 -08:00
Derek Collison
7facbc995b More robust key detection per feedback
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-12 18:23:16 -08:00
Derek Collison
d803189eca Changes needed to properly support multi-layer service imports for system services like JS.
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-12 17:01:32 -08:00
Derek Collison
eadb801d0d Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-11 22:13:01 -08:00
Derek Collison
e07cf84985 Merge pull request #1906 from nats-io/snapshots
Snapshot and Compaction Improvements
2021-02-11 22:44:36 -07:00
Derek Collison
5ef4d138cb Interest based retention did not work correctly with wildcards or multiple subjects and filtered consumers.
This allows that to work properly, needed for MQTT.

Signed-off-by: Derek Collison <derek@nats.io>
2021-02-11 20:59:20 -08:00
Derek Collison
d70ae1fb97 Fix for interest policy based retention for streams in clusters.
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-11 18:52:37 -08:00
Derek Collison
579737a5e1 General fixes, stability improvements
Signed-off-by: Derek Collison <derek@nats.io>
2021-02-11 18:13:24 -08:00