Thales Macedo Garitezi
|
f1294736b7
|
feat(ds): add filter for message persistence
Fixes https://emqx.atlassian.net/browse/EMQX-10520
|
2023-09-11 16:25:34 -03:00 |
|
Thales Macedo Garitezi
|
fe4640922d
|
feat(ds): add delete callback
|
2023-09-11 16:25:33 -03:00 |
|
Thales Macedo Garitezi
|
23d63f5e01
|
refactor: fork clientid type for `emqx_ds:session_id/0`
|
2023-09-04 15:38:25 -03:00 |
|
Thales Macedo Garitezi
|
922ca5e141
|
feat(ds): close iterators when handling `UNSUBSCRIBE` packets
Fixes https://emqx.atlassian.net/browse/EMQX-9742
|
2023-08-30 11:14:28 -03:00 |
|
Thales Macedo Garitezi
|
33a0048155
|
refactor: move logic to `ensure_iterator`
|
2023-08-25 15:24:53 -03:00 |
|
Thales Macedo Garitezi
|
ee2897e5de
|
test(refactor): move test to integration tests dir
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
dad27091be
|
test: rm custom option
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
dbfacae283
|
fix: reinstate transactions
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
3344bfb0bd
|
refactor: rm `emqx_ds_replay`
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
6de0bbe76a
|
test(refactor): always allocate listeners for emqx app
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
021755b82b
|
refactor: rm iterators from DS `#session{}` record
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
e4e88ebf36
|
test: add scenario for node stopping midway during subscribe
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
3239f5ac5b
|
feat: rm unnecessary transactions, use separate table for iterator references
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
8eab389ae1
|
perf: avoid unnecessary transaction
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
9463e271c0
|
feat(ds): open iterators when handling `SUBSCRIBE` packets
Fixes https://emqx.atlassian.net/browse/EMQX-9741
|
2023-08-22 13:29:15 -03:00 |
|
Thales Macedo Garitezi
|
ca697a4e14
|
fix: rename `emqx_ds{,_replay}:replay_id()`
|
2023-08-22 13:29:15 -03:00 |
|
firest
|
abf8d8b391
|
fix(ds): make dialyzer happy
|
2023-07-26 16:35:07 +08:00 |
|
firest
|
14b76916df
|
fix(ds): avoid crashes when starting on Windows
|
2023-07-26 15:37:58 +08:00 |
|
Andrew Mayorov
|
8c883feb54
|
chore: bump `emqx_durable_storage` to 0.1.1
|
2023-07-07 21:56:21 +02:00 |
|
Andrew Mayorov
|
daf4e86da1
|
feat(ds): add `ensure_shard/2` shortcut
And use it in `emqx_persistent_session_ds:init()` backend initialization
function.
|
2023-07-07 21:56:20 +02:00 |
|
Andrew Mayorov
|
ac56de9fc5
|
feat(ds): allow to redefine directory for shard's rocksdb
|
2023-07-07 21:56:20 +02:00 |
|
ieQu1
|
940ad12108
|
docs(ds): Apply suggestions from code review
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
|
2023-06-28 10:04:07 +02:00 |
|
ieQu1
|
e0c11f54aa
|
docs(ds): Update IMPLEMENTATION.md
|
2023-06-27 10:53:38 +02:00 |
|
ieQu1
|
9a81f22105
|
fix(ds): Apply review remarks
|
2023-06-22 17:07:30 +02:00 |
|
ieQu1
|
cfcd81e17b
|
fix(ds): Fix build
|
2023-06-22 11:07:52 +02:00 |
|
ieQu1
|
b29c5ad23c
|
feat(emqx_ds): Add API draft for logic layer
|
2023-06-22 10:20:18 +02:00 |
|
ieQu1
|
a343cdb1d5
|
refactor(ds): message_storage -> message_storage_bitmask
|
2023-06-22 10:20:18 +02:00 |
|
ieQu1
|
a4219db163
|
refactor(ds): emqx_ds_local_store -> emqx_ds_storage_layer
|
2023-06-22 10:20:18 +02:00 |
|
ieQu1
|
1159f99432
|
refactor(ds): emqx_replay -> emqx_ds
|
2023-06-22 10:20:18 +02:00 |
|
ieQu1
|
8d6bcc1414
|
refactor(ds): emqx_replay -> emqx_durable_storage
|
2023-06-22 10:20:18 +02:00 |