Andrew Mayorov
|
70396e9766
|
Merge pull request #12825 from keynslug/feat/EMQX-12110/repl-meta-api
feat(dsrepl): add APIs to manage DB replication sites
|
2024-04-04 22:32:03 +02:00 |
|
Andrew Mayorov
|
ad52f7838e
|
feat(dsrepl): add APIs to manage DB replication sites
|
2024-04-04 21:22:01 +02:00 |
|
ieQu1
|
f37ed3a40a
|
fix(ds): Limit the number of retries in egress to 0
|
2024-04-03 16:38:49 +02:00 |
|
ieQu1
|
94ca7ad0f8
|
feat(ds): Report counters for LTS storage layout
|
2024-04-02 16:47:43 +02:00 |
|
ieQu1
|
75b092bf0e
|
fix(ds): Actually retry sending batch
|
2024-04-02 16:45:49 +02:00 |
|
Andrew Mayorov
|
c666c65c6a
|
test(ds): factor out storage iteration into helper module
|
2024-04-02 13:48:51 +02:00 |
|
Andrew Mayorov
|
5cc0246351
|
feat(dsrepl): allow to tune select ra options
|
2024-03-19 20:21:55 +01:00 |
|
Andrew Mayorov
|
e6c2c2fb07
|
feat(dsrepl): manage generations / db config through ra machine
|
2024-03-19 20:11:39 +01:00 |
|
Ivan Dyachkov
|
f2dc940436
|
Merge remote-tracking branch 'upstream/release-56' into 0319-sync-release56
|
2024-03-19 15:20:08 +01:00 |
|
Thales Macedo Garitezi
|
6af01b916e
|
feat(ds): implement `get_delete_streams`, `make_delete_iterator` and `delete_next` callbacks for builtin storage
Part of https://emqx.atlassian.net/browse/EMQX-11841
|
2024-03-08 09:56:46 -03:00 |
|
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 |