gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 19:14:41 -07:00
Code Issues Packages Projects Releases Wiki Activity
2,597 Commits 30 Branches 48 Tags
c3a5df135feb2b6e5a5f0ddc98a9ddbc2ec0101f
Commit Graph

2597 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Derek Collison
c3a5df135f Observable state storage 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
0e426df281 Sync timer and read ahead 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
fa99ffa176 Read cache expiration 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
5cf03fd074 Remove performance, dmap collapse logic 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
613d65c58c Erased msg recovery, bug fix on linux for idx file, LoadMsg vs Lookup 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
e8f465eaf3 Filestore read perf, secure delete for stores 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
4afdfafd89 Bitrot protection and tests 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
62fcfcd84d filestore updates 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
39aba7de92 filestore first pass 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:12:28 -07:00
Derek Collison
75908f80a4 API cleanup 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
da7838368d Tracking usage and limits 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
b7b98df4ee Server limits and account reservations 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
8ba8abfab9 Observable replay policy to control rate of replay 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
7e00a975b1 Add purge and interest retention tests 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
171a59754d Implement delivery count, nak checks, no restart on nak 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
b8c958ed07 Nak as restart semantics on push based observable 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
98bd8234b6 Rework of delivery sequence vs store sequence and ack reply subjects 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
68c9394a3f Make sure to update pending timestamp on redelivery 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
ac40ecaef9 Durable reassignment and takeover 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
77c75baa6e Flush first progress ack 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
0fb7ee32bc Auto-expiration of ephemeral push based observables 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
d02b2a3d9c NoAck option for MsgSets 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
d327a91143 Working ACK indicator 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
4eee93dea0 NAK for workers 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
0a92d8e87d AckWait and redelivery 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
ccbd3d6032 cleanup 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
5576463635 ack prep 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
16e6952cd6 Move load balance test to norace 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
4698292d4f Added push based observable no ack benchmark 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
5d5d5cbd60 Add AckNext and batch size for worker pull mode 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
a9d1989047 test updates 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
ea85d0130f Reworked load balance test 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
cd3c1c7a3f Basic partitioning 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Derek Collison
98b78d06c4 First pass pull mode, e.g. worker 
Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:07:02 -07:00
Ivan Kozlovic
9214fa2995 Update expiration test 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-19 14:06:29 -07:00
Ivan Kozlovic
09c1acc36c Fix message expiration 
Also add missing `package` for sysmem/windows

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-19 14:06:29 -07:00
Derek Collison
dd116fcfd4 JetStream first pass basics. 
This is the first checkin for JetStream. Has some rudimentary basics working.

TODO
1. Push vs pull mode for observables. (work queues)
2. Disk/File store, memory only for now.
3. clustering code - design shaping up well.
4. Finalize account import semantics.
5. Lots of other little things.

Signed-off-by: Derek Collison <derek@nats.io>
 2020-05-19 14:06:29 -07:00
Ivan Kozlovic
2b8ebfcf07 Merge pull request #1403 from nats-io/account_system_operator 
Pointing to jwt master
 2020-05-19 14:25:47 -06:00
Matthias Hanel
84e52bfb44 Pointing to jwt master 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-05-19 16:06:22 -04:00
Ivan Kozlovic
92cb24c5f2 Merge pull request #1400 from nats-io/account_system_operator 
Account system operator
 2020-05-19 13:48:18 -06:00
Matthias Hanel
aa1a768cce Move system account check to validateTrustedOperators 
As a consequence of this change, certain unit tests had to actually
start the server and move to a memory resolver to keep the test simpler.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-05-19 15:39:18 -04:00
Matthias Hanel
e509ec59a1 Raise error when system_account in config and operator jwt do not match 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-05-18 23:35:43 -04:00
Matthias Hanel
a2744858bc Looking up system_account from operator jwt 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-05-18 19:09:46 -04:00
Matthias Hanel
a989024075 Picking up jwt branch corresponding to this change 
Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-05-18 18:57:39 -04:00
Ivan Kozlovic
bf0930ee76 Merge pull request #1394 from nats-io/release_2_1_7 
Release v2.1.7
v2.1.7 		2020-05-14 11:33:56 -06:00
Ivan Kozlovic
b329215af3 Release v2.1.7 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
 2020-05-13 19:40:49 -06:00
Ivan Kozlovic
54e014070f Merge pull request #1392 from guilherme-santos/master 
[ADDED] base path for monitoring endpoints
 2020-05-13 16:28:57 -06:00
Guilherme Santos
25858cba0b Implement basePath for monitoring endpoints 2020-05-13 23:29:11 +02:00
Ivan Kozlovic
0c3acfbaad Merge pull request #1393 from nats-io/internal_client_reload 
Move reset of internal client to after the account sublist was moved.
 2020-05-13 14:43:30 -06:00
Matthias Hanel
d486f6ab9b Move reset of internal client to after the account sublist was moved. 
This does not avoid the race condition, but makes it less likely to
trigger in unit tests.

Signed-off-by: Matthias Hanel <mh@synadia.com>
 2020-05-13 15:52:29 -04:00