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,215 Commits 30 Branches 48 Tags
0bdd8f84f92e54f30358722b7ae5663ddb77eaaa
Commit Graph

4215 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Ivan Kozlovic
0bdd8f84f9 Merge pull request #2062 from nats-io/release_2_2_1 
Release v2.2.1
v2.2.1 		2021-04-02 16:53:50 -06:00
Ivan Kozlovic
c2ee75303b Release v2.2.1 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-04-02 16:38:10 -06:00
Ivan Kozlovic
fbaae34e84 Merge pull request #2061 from nats-io/fix_mqtt 
[FIXED] MQTT: make sure unsubscribe is propagated
 2021-04-02 15:44:34 -06:00
Matthias Hanel
b154c3d957 [Fixed] remote subscription leak for leafnodes caused by auto unsubscribe 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-04-02 17:38:57 -04:00
Ivan Kozlovic
8a4e1f688a [FIXED] MQTT: make sure unsubscribe is propagated 
In error conditions or when replacing an existing sub qos1 to qos0,
we were unsubscribing the NATS subscription, but that would not
have been propagated across the cluster.

Also fixed a flapper

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-04-02 15:30:27 -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
bd6a36b10d Merge pull request #2058 from nats-io/cinfo 
During repeated server restarts or failures consumer state could drift between replicas.
 2021-04-02 09:07:06 -07:00
Derek Collison
2009578e8d Fix data race 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-04-02 08:42:37 -07:00
Derek Collison
44ada49b16 During repeated server restarts or failures consumer state could drift between replicas. 
We now make sure to sync state of the replicas when a new leader takes over. We also update ack floors regardless of detection on pending list.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-04-02 08:20:29 -07:00
Derek Collison
f89376d106 Merge pull request #2056 from nats-io/pubsubperf 
Aggressive cache expiration was hindering performance
 2021-04-01 16:42:52 -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
c6bb9b0644 Fix test since we moved from 500 to 404 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-04-01 07:09:10 -07:00
Derek Collison
bea180d19e Merge pull request #2053 from nats-io/get_msg 
Fix for #1976
 2021-04-01 05:26:37 -07:00
Matthias Hanel
cd602231ac [Fixed] missing unlock and added a warning trace (#2054) 
* [Fixed] missing unlock and added a warning trace

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-31 19:22:19 -04:00
Derek Collison
ceca86a79c Fix for #1976 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-31 11:23:31 -07:00
Matthias Hanel
da5c0849b8 Merge pull request #2052 from nats-io/nats-go-update 
Updated go client for unit tests and fixing test
 2021-03-31 12:21:54 -04:00
Matthias Hanel
e390958beb Updated go client for unit tests and fixing test 
One test had a race.
For the other one, the updated go client changed the callback used.s

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-30 21:46:39 -04:00
Waldemar Quevedo
17836014f2 Merge pull request #2051 from wallyqs/fix-user-revokation-test 
Fix to authentication revoked test
 2021-03-30 14:44:44 -07:00
Waldemar Quevedo
5ec0c35afb Fix to authentication revoked test 
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
 2021-03-30 14:19:15 -07:00
Derek Collison
0650b772a9 Fix test, needed prefix 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-30 13:46:03 -07:00
Waldemar Quevedo
cb31225465 Merge pull request #2022 from nats-io/client-update 
Update to newer Go client for tests
 2021-03-30 13:31:36 -07:00
Jaime Piña
6941bb3ade Update Go client in tests 2021-03-30 13:17:34 -07:00
Derek Collison
10ba6c95ba Merge pull request #2049 from nats-io/dconsumer 
Fix for performance degradation on durable consumers R>1.
 2021-03-30 12:24:39 -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
14a826fb60 Check for entries going negative. Shutdown in place on server exit 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-30 11:46:15 -07:00
Matthias Hanel
61cbd74e21 Merge pull request #2048 from nats-io/jwt-remove 
Enhance Jwt remove by allowing operator signing keys to sign the remove request.

It is reasonable for a customer to expect clients of the removed account to be disconnected.
Absent account cleanup, expire the account.
 2021-03-30 11:50:36 -04:00
Matthias Hanel
6ffe9adf97 [added] disconnect of all clients and disable account on remove 
Error sent to the client: Account Authentication Expired

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-30 02:24:02 -04:00
Matthias Hanel
c3479d339e [added] ability to remove account jwt using an operator signing key 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-29 23:58:28 -04:00
Ivan Kozlovic
778313cc45 Merge pull request #2047 from nats-io/fix_ws_random_port_display 
[FIXED] Websocket: print correct random port instead of `0`
 2021-03-29 19:07:05 -06:00
Ivan Kozlovic
9c036778c0 [FIXED] Websocket: print correct random port instead of 0 
When a random port is selected (likely in tests), the banner would
print the port as `0` instead of its real value.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-03-29 16:01:38 -06:00
Derek Collison
874e13f5b9 Merge pull request #2036 from nats-io/fix-race 
Guard account client map
 2021-03-29 09:25:04 -07:00
Derek Collison
ad9e12079c Merge pull request #2045 from nats-io/RC11 
RC11
 2021-03-29 08:21:49 -07:00
Derek Collison
389c3882be Update based on staticcheck update 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-29 07:48:39 -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
327d913ae1 Under rare scenarios we could fail to load, but this should not be a panic. 
We should recover on the lines below.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-29 07:34:28 -07:00
Derek Collison
c8d812d805 Release server lock when getting usage 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-27 17:38:57 -07:00
Matthias Hanel
03aee09847 [Added] error when mirror/source stream prefix overlaps with stream subs (#2041) 
* [Added] error when mirror/source stream prefix overlaps with stream subs

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-27 14:01:51 -04:00
Matthias Hanel
9f753a2475 [fixed] issue where verify_and_map: true in leaf node config was not used (#2038) 
* [fixed] issue where verify_and_map: true in leaf node config was not used

This broke the setup in such a way that any connect relying on this would have failed.
This also fixes an issue where specifying no account did not result in using $G.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-26 19:24:01 -04:00
Ivan Kozlovic
b732109881 Merge pull request #2040 from nats-io/ws_fix 
[FIXED] Websocket: do not generate empty frames + LN corruption
 2021-03-26 17:23:18 -06:00
Ivan Kozlovic
b17f38e356 [FIXED] Websocket: do not generate empty frames + LN corruption 
- It was possible that when the server was sending frames to a
webbrowser, it would send empty frames. While technically not wrong,
prevent that from happening.
- Not copying enqueued buffers could cause corruption with LN+WS.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-03-26 16:17:46 -06:00
Derek Collison
36677d63fd Merge pull request #2039 from nats-io/faster_consumer 
Durable consumers with R>1 had performance challenges.
 2021-03-26 14:42:40 -07:00
Derek Collison
6c702b3b5d RC10 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-26 14:41:09 -07:00
Derek Collison
0f71c260fb Durable consumers with R>1 had performance challenges. 
This code changes the way we handle raft based proposals for consumers.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-26 12:53:49 -07:00
Ivan Kozlovic
ecfe9cf538 Merge pull request #2037 from nats-io/update_travis 
Update travis
 2021-03-26 12:38:51 -06:00
Jaime Piña
6095e8f46d Guard account client map 2021-03-26 10:30:16 -07:00
Ivan Kozlovic
5bb236cef0 Update travis 
- For tags, only run the version check test.
- Ping goreleaser to last version that works with vendor for now.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2021-03-26 11:24:48 -06:00
Derek Collison
3adbbd3069 Merge pull request #2034 from nats-io/memstore_locking 
Calling out to the storage update should not hold lock.
 2021-03-26 05:41:43 -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
c564b18482 Protect against negative 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-26 05:28:00 -07:00