Andrew Mayorov
|
f7e3afde16
|
test(ds): avoid introducing new macros
|
2024-03-07 16:49:20 +01:00 |
|
Andrew Mayorov
|
69427dc42d
|
test(ds): add tests for error mapping and replay recovery
|
2024-03-07 12:59:58 +01:00 |
|
Andrew Mayorov
|
2146d9e1fe
|
feat(ds): introduce error classes in critical API functions
For now, only recoverable / unrecoverable errors are introduced.
|
2024-03-07 12:59:57 +01:00 |
|
Thales Macedo Garitezi
|
5d87d400f4
|
feat(ds): add atomic store API
Part of https://emqx.atlassian.net/browse/EMQX-11841
|
2024-03-06 15:24:14 -03:00 |
|
ieQu1
|
137535a821
|
feat(ds): Introduce egress process for the builtin backend
|
2024-01-24 19:33:30 +01:00 |
|
Thales Macedo Garitezi
|
75b08b525b
|
feat(ds): add `list_generations` and `drop_generation` APIs
|
2024-01-22 14:53:17 -03:00 |
|
Ilya Averyanov
|
9e0f3ce53b
|
feat(ds): restore original add_generation/update_db_config callback semantics
|
2023-12-29 13:12:15 +03:00 |
|
firest
|
ed38ca67d5
|
fix(ds): Unified the names of the `add_generation` API
|
2023-12-20 18:58:03 +08:00 |
|
firest
|
31060733a5
|
feat(ds): add an API for making new generations
|
2023-12-15 16:08:52 +08:00 |
|
Thales Macedo Garitezi
|
66d043becd
|
feat(ds): introduce `update_iterator` callback
|
2023-12-08 15:04:18 -03:00 |
|
Thales Macedo Garitezi
|
2a6d72878f
|
chore(ds): return DS message key along with batch
|
2023-12-07 11:36:08 -03:00 |
|
ieQu1
|
2a1f7d946a
|
feat(ds): Shard messages by publisher client ID
|
2023-11-21 19:37:01 +01:00 |
|
ieQu1
|
62542e5844
|
feat(ds): Metadata storage for the replication layer
|
2023-11-21 19:37:01 +01:00 |
|
ieQu1
|
8dc8237331
|
feat(ds): Introduce emqx_ds behavior
|
2023-11-10 12:16:39 +01:00 |
|
ieQu1
|
7428e7037b
|
feat(ds): Bitfield + Learned Topic Structure
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
c149e0e2df
|
fix(ds): Pass topic filter to emqx_ds:make_iterator call
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
2972bf14ee
|
refactor(ds): Implement create_generation gen_rpc storage layer call
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
6d65707d41
|
refactor(ds): Implement drop_db function
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
c6a721a7eb
|
refactor(ds): Passthrough open_db and get_channels to storage layer
|
2023-11-08 03:04:19 +01:00 |