Derek Collison
f0cdf89c61
JetStream Clustering WIP
...
Signed-off-by: Derek Collison <derek@nats.io >
2021-01-14 01:14:52 -08:00
Derek Collison
7564768027
Added Compact to store interface for WAL functionality
...
Signed-off-by: Derek Collison <derek@nats.io >
2020-12-03 16:18:58 -08:00
Derek Collison
0d2ca9ba54
Fix race, can't clear direct memory since shared
...
Signed-off-by: Derek Collison <derek@nats.io >
2020-06-02 06:19:04 -07:00
Derek Collison
eca04c6fce
First pass header support for JetStream
...
Signed-off-by: Derek Collison <derek@nats.io >
2020-05-30 10:04:23 -07:00
R.I.Pienaar
fb37c121d1
expose the arrival timestamp in the message metadata
...
Signed-off-by: R.I.Pienaar <rip@devco.net >
2020-05-19 14:21:27 -07:00
Derek Collison
323b3d0b11
Beginning basics for stream and consumer snapshotting
...
Signed-off-by: Derek Collison <derek@nats.io >
2020-05-19 14:18:34 -07:00
Derek Collison
47c28b2fb0
JetStream major refactor for name changes.
...
MsgSet -> Stream
Observable -> Consumer
Signed-off-by: Derek Collison <derek@nats.io >
2020-05-19 14:16:03 -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
39aba7de92
filestore first pass
...
Signed-off-by: Derek Collison <derek@nats.io >
2020-05-19 14:12:28 -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
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
