316 Commits

Author SHA1 Message Date
Ivan Kozlovic
38dcc79b3b Release v2.2.2
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-04-22 11:14:09 -06:00
Derek Collison
cc776302a0 2.2.2-beta.11
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-21 08:48:49 -07:00
Derek Collison
d31041ecd9 2.2.2-beta.10
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-21 06:57:07 -07:00
Derek Collison
1d7522581f 2.2.2-beta.8
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-20 06:06:39 -07:00
Derek Collison
68ddd519d2 Process upstream missing messages for mirrors better.
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-19 20:15:21 -07:00
Derek Collison
6e973a8d59 Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-18 18:48:11 -07:00
Derek Collison
8f07929530 2.2.2-beta.5
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-15 17:35:28 -07:00
Derek Collison
14627434c9 Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-15 04:53:27 -07:00
Derek Collison
1127c5d771 Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-13 20:08:29 -07:00
Derek Collison
8645935ccd Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-12 11:43:11 -07:00
Derek Collison
6024c85c09 Bump to 2.2.2-beta
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-07 17:44:30 -07:00
Ivan Kozlovic
c2ee75303b Release v2.2.1
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-04-02 16:38:10 -06:00
Matthias Hanel
edee54b005 [Adding] (fetch) timeout to nats resolver (#2057)
* [Adding] (fetch) timeout to nats resolver

Signed-off-by: Matthias Hanel <mh@synadia.com>
2021-04-02 12:27:02 -04:00
Derek Collison
14793177c5 RC15
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-02 09:09:11 -07:00
Derek Collison
c3ec8d9fb3 Agressive cache expiration was hindering performance when publishing and receiving from a stream concurrently.
Signed-off-by: Derek Collison <derek@nats.io>
2021-04-01 16:32:43 -07:00
Derek Collison
bb7a8a5f79 Introduced default max ack pending for ack explicit.
Fixed a bug that would introduce performance degradation for durable consumers R>1.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-30 11:47:24 -07:00
Derek Collison
5a48369b4b Make sure to not delete streams on bad updates.
If an update was asssigned but failed at the stream group server we would send back the result which would always delete the stream.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-29 07:35:30 -07:00
Derek Collison
6c702b3b5d RC10
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-26 14:41:09 -07:00
Derek Collison
2d2938239f Bump to RC9
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-26 05:28:23 -07:00
Derek Collison
a75e8f8c80 Fix for an issue with multiple restarts that showed stalled and sometimes lost streams.
The issue was when a state was removed from a server and restarted it would catch up properly.
However upon cluster restart the system could exhibit strange behaviors. This was due to on
catchup not properly creating a meta snapshot when one was received, leaving no meta state to recover.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-22 20:06:38 -07:00
Derek Collison
022c5b4ab2 Fix for bad behavior with flow control and multiple sources streams.
Allow chaining of sources and mirrors with filtered consumers.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-22 11:13:51 -07:00
Derek Collison
0f548edcc6 Reduce sliding window for direct consumers and catchup stream windows.
Remove another possible wire blocking operation in raft.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-21 09:24:27 -07:00
Derek Collison
0bcda04a9d Send both last consumer and stream sequence for idle hb
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 16:57:13 -07:00
Derek Collison
2d46c112d6 Make sure to not interrupt flow control unless we miss.
Fix deadlock for mirrors.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 15:05:41 -07:00
Derek Collison
ced35e5b8c Reworked sources and mirrors on missed data.
Add last delivered sequence to consumer idle heartbeats.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 14:03:46 -07:00
Derek Collison
4c6fd179d6 Can not use sub comparisons for old messages from direct consumers.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 10:30:09 -07:00
Derek Collison
61771e88f8 In operator mode with JetStream we want to load accounts that have stable storage.
Also if an account was registered but not JetStream enabled, update it vs error.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-20 06:53:13 -07:00
Derek Collison
aa0c3e12ac Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-18 06:46:28 -07:00
Ivan Kozlovic
0d5b037fc3 Release v2.2.0
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-03-14 19:51:14 -06:00
Derek Collison
1eaa2f7572 RC10
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 11:39:30 -07:00
Derek Collison
ef82de2ef2 Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 07:31:16 -07:00
Derek Collison
0425056c33 Fix deadlock
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 05:38:25 -07:00
Derek Collison
3c85df0a44 Truncate up to entry, no need for previous
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-14 05:18:52 -07:00
Derek Collison
e07724f16c Bump version
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-13 16:28:24 -05:00
Derek Collison
18d0a0f94d Version bump
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-13 16:28:24 -05:00
Derek Collison
d5ab019abb RC8
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-11 07:43:56 -05:00
Ivan Kozlovic
738527a37c Bump version
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-03-10 19:36:49 -07:00
Derek Collison
709335f1c2 Bump to RC7.4 2021-03-10 07:18:43 -05:00
Ivan Kozlovic
ccec4a6ab1 Fixed consumer idle hearbeats and JS route/GWs unsubscribes
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
2021-03-09 12:08:47 -07:00
Derek Collison
ea9abc5ef8 Wait longer for response
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-09 05:41:00 -06:00
Derek Collison
e5e8205fac Need to make sure order of clseq as stamped also make it to the propose chan.
However we do not want to hold the actual stream lock.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-09 00:34:33 -06:00
Ivan Kozlovic
4d1fc3a449 Merge pull request #1974 from nats-io/pae
Memory cache for commits and WAL size constraints.
2021-03-08 16:43:20 -07:00
Derek Collison
513cb061e3 Bump Version 2021-03-08 15:43:15 -06:00
Derek Collison
d31fda5dac Added code to constrain size of WAL under most scenarios.
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-06 08:38:56 -08:00
Waldemar Quevedo
4448989091 Skip TERM signal during lame duck mode
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
2021-03-06 00:16:58 -08:00
Derek Collison
ff98984358 Reworked internal consumers used for sources and mirrors.
Now use ephemerals and heartbeats and flowcontrol.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-05 14:32:57 -08:00
Derek Collison
051d0159ef rc5
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-04 14:46:59 -08:00
Derek Collison
d7201a110b Better handling on out of disk.
Suppress some stream and consumer bad results since they delete the asset.
Allow rehup to re-enable JetStream.
Various bug fixes and improvements.

Signed-off-by: Derek Collison <derek@nats.io>
2021-03-03 20:12:10 -08:00
Derek Collison
0b8c070d8e Bump Version
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-02 07:31:45 -08:00
Derek Collison
29421bde67 Bump to RC2
Signed-off-by: Derek Collison <derek@nats.io>
2021-03-01 20:00:06 -08:00