gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity
3,949 Commits 30 Branches 48 Tags
32ffb55a220adbe4cd5c49db08e532d487df9530
Commit Graph

3949 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Derek Collison
32ffb55a22 Provide feedback to users when trying to pull from a push based consumer. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 09:17:27 -08:00
Derek Collison
2ecf6be3ef Mark raft node as offline when server is removed 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 08:06:45 -08:00
Derek Collison
d170647c04 More time to make sure mirror consumer has hooked up properly 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 07:58:45 -08:00
Derek Collison
5da343eed8 More time for consumer delivered state to propagate 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 07:43:03 -08:00
Derek Collison
b7cf49949e For large redeliver queues linear search was not good, so added index. 
Also set to nil when drained to avoind holding onto large underlying arrays.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 07:29:59 -08:00
Derek Collison
e4d458c3f8 Make consumer processing of next message not inline if non client connection. 
Also fixed a bug with processing ack floors.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 06:52:56 -08:00
Derek Collison
af6b5d856a Better errors, no need to wait on leader twice 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 06:45:27 -08:00
Derek Collison
e8029094e3 Cleanup export and import processing 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 06:35:52 -08:00
Derek Collison
401484299d Flaps with cluster size of 5 too much 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 06:34:07 -08:00
Derek Collison
c6b0ed6069 Flapping test 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-03 05:06:24 -08:00
Derek Collison
00a49ce329 Test for existing service import 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 20:38:16 -08:00
Derek Collison
e1f7440361 Revert to previous, will redo out of band version 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 20:18:21 -08:00
Derek Collison
43b9017b74 Merge pull request #1953 from nats-io/api 
JetStream API Changes
 2021-03-02 19:46:00 -07:00
Matthias Hanel
25ef6b0f0d Merge pull request #1952 from nats-io/goland-lint 
Fixed linter issues
 2021-03-02 21:43:04 -05:00
Derek Collison
b9498b8c0e Need to return 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 18:38:05 -08:00
Matthias Hanel
c50ee2a1c6 [Changed] all times exposed will be computed in UTC (#1943) 
This also applies to times that end up in that json.
Where applicable moved time.Now() to where it is used.
Moved calls to .UTC() to where time is created it that time is converted
later anyway.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-02 21:37:42 -05:00
Derek Collison
4583afc2b0 Updated comment 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 18:36:28 -08:00
Derek Collison
d084853aff Actually need to wait to accumulate, make sure we get at least 8. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 18:33:22 -08:00
Derek Collison
df02e0be71 Consumers would process next message batches inline. 
In clustered mode this could block a route or gateway processor.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 18:28:17 -08:00
Derek Collison
04634d3358 One less api call 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 18:28:06 -08:00
Derek Collison
479176d26c Adjustments for change in actual JSApi subs 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 18:08:08 -08:00
Derek Collison
c39a2d6bd0 If capturing calls with no dispatch just return 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 17:58:34 -08:00
Derek Collison
4f7fbefc7c In clustered JetStream we need to move API calls out of routes/gateways/leafnodes path. 
This moves from explicit imports and subscriptions to one wildcard subscription and a single wildcard export.

Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 17:54:41 -08:00
Matthias Hanel
4f2db7d187 Fixed linter issues 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2021-03-02 20:21:44 -05:00
Derek Collison
0b8c070d8e Bump Version 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 07:31:45 -08:00
Derek Collison
a3c526a0eb Merge pull request #1951 from nats-io/xmirrors 
Enable cross account behaviors for mirrors and sources.
 2021-03-02 08:30:48 -07:00
Derek Collison
27090975d9 Fix for leaked subs on non-leader change 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 07:19:18 -08:00
R.I.Pienaar
84f4b0fc44 Merge pull request #1950 from ripienaar/meta_peer_remove_id 
update api types, remove meta peer by id
 2021-03-02 16:14:28 +01:00
Derek Collison
2e7fdf2ef8 Only updateDelivered needs to be suppressed for leaders 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 07:03:32 -08:00
Derek Collison
49cd38c064 Enable cross account behaviors for mirrors and sources. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 06:36:57 -08:00
R.I.Pienaar
a9ed69a2df update api types, remove meta peer by id 
Signed-off-by: R.I.Pienaar <rip@devco.net>
 2021-03-02 15:35:02 +01:00
Derek Collison
d4a8baf030 Stabilize test, wait a bit for migration 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-02 05:28:55 -08:00
Derek Collison
29421bde67 Bump to RC2 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 20:00:06 -08:00
Derek Collison
5b54a7e3be Merge pull request #1949 from nats-io/rc2 
Consumers were double processing as leaders.
 2021-03-01 20:58:22 -07:00
Derek Collison
9e181b8d0d Consumers were double processing as leaders 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 18:37:35 -08:00
Derek Collison
e817ecfb80 Wait for consumer migration 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 17:10:10 -08:00
Derek Collison
22749fb1e2 Fix data race, stabilize usage test 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 16:47:19 -08:00
Derek Collison
1a58fc2393 Merge pull request #1948 from nats-io/s2 
Stability Updates
 2021-03-01 17:41:11 -07:00
Derek Collison
c8e2ad6248 Make sure trailing usage updates accounted for eventually 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 14:23:06 -08:00
Derek Collison
2d70429f83 More conservative in replay 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 14:22:27 -08:00
Derek Collison
e0353479ad Progress updates could potentially block on channels, this cleans that up. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 13:52:49 -08:00
Derek Collison
f16d9c6ea8 Don't forget last message 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 12:52:54 -08:00
Derek Collison
c0729a1309 Move processing of append entry response out of route path. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 05:57:15 -08:00
Derek Collison
84d042c4e2 Make sending account usage updates more efficient 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 04:42:50 -08:00
Derek Collison
a8db1d7322 Write snapshots without lock held 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-03-01 04:42:11 -08:00
Derek Collison
0dcdb9fb1c RC1 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 19:54:26 -08:00
Derek Collison
59148b1b36 Merge pull request #1947 from nats-io/rcc 
Stability Fixes, bug fixes, RC features.
 2021-02-28 20:53:36 -07:00
Derek Collison
fbc492fef7 Use .Equal 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 19:11:55 -08:00
Derek Collison
74b416afa1 Moved back to channel handling of append entry to avoid inline processing with disk IO in route path. 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 18:34:24 -08:00
Derek Collison
0a6958b98c Fix some flapping tests 
Signed-off-by: Derek Collison <derek@nats.io>
 2021-02-28 17:35:09 -08:00