Zaiming (Stone) Shi
|
d560366c14
|
test: fix some compile warnings
|
2023-12-11 09:43:13 +01:00 |
|
Zaiming (Stone) Shi
|
50f4aba5cd
|
fix(dialyzer): batch 3
|
2023-12-09 15:50:09 +01:00 |
|
Zaiming (Stone) Shi
|
ddbb8560fa
|
fix(dialyzer): batch 2
|
2023-12-08 17:59:55 +01:00 |
|
Andrew Mayorov
|
130a5a5442
|
fix(ds): pass topics to `emqx_topic:words/1` before feeding LTS tree
So that empty levels in topics will be properly mapped into `''` atoms.
|
2023-12-04 13:39:01 +03:00 |
|
ieQu1
|
e238602533
|
fix(ds): Update README
|
2023-12-01 08:27:05 +01:00 |
|
ieQu1
|
0ae618d010
|
fix(ds): Use emqx_rpc for calls that work with large binaries
|
2023-12-01 08:27:05 +01:00 |
|
Ivan Dyachkov
|
9fd2fa95a8
|
chore: bump apps versions
|
2023-11-30 20:01:12 +01:00 |
|
ieQu1
|
05e47254e2
|
fix(ds): Fixes related to the shards table
|
2023-11-28 12:59:09 +01:00 |
|
ieQu1
|
e8d18b0e09
|
Merge pull request #12014 from ieQu1/ds-qos0
Support QoS0 messages in persistent_session_ds
|
2023-11-23 23:43:18 +01:00 |
|
ieQu1
|
449bafc27e
|
fix(ds): LTS trie handles empty topic levels
|
2023-11-23 22:16:38 +01:00 |
|
ieQu1
|
c5bb86db67
|
feat(ds): Support QoS 0
|
2023-11-23 22:16:38 +01:00 |
|
ieQu1
|
1da9ec1d7d
|
Merge pull request #12015 from ieQu1/ds-lts-dont-store-message
feat(ds): Don't store #message record in the DB
|
2023-11-23 18:56:45 +01:00 |
|
ieQu1
|
c69b82455e
|
feat(ds): Don't store #message record in the DB
|
2023-11-23 17:56:35 +01:00 |
|
Ilya Averyanov
|
29d42506d5
|
fix(ds): impose more flexible types for ds implementations
|
2023-11-23 17:16:11 +03:00 |
|
Ilya Averyanov
|
a1b9a14fa1
|
feat(ds): allow fdb implementation for durable storage
|
2023-11-22 14:49:38 +03:00 |
|
ieQu1
|
3165b4f645
|
fix(ds): Abort application startup when rocksdb is not avialable
|
2023-11-21 20:27:07 +01:00 |
|
ieQu1
|
3d823beb11
|
fix(ds): Apply review remarks
|
2023-11-21 19:37:01 +01:00 |
|
ieQu1
|
f5c71e8068
|
refactor(ds): Add a wrapper to the store batch API
|
2023-11-21 19:37:01 +01: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 |
|
Ivan Dyachkov
|
28a577ad09
|
chore: bump apps versions
|
2023-11-14 11:02:26 +01:00 |
|
Thales Macedo Garitezi
|
088de9476c
|
fix(ds): use integer for tag values
Follow up to https://github.com/emqx/emqx/pull/11906#discussion_r1389115973
|
2023-11-10 11:26:32 -03:00 |
|
ieQu1
|
2ade6da7a6
|
fix(ds): Remove redundand type
|
2023-11-10 12:53:30 +01:00 |
|
ieQu1
|
feef23fc08
|
feat(ds): Pass store_batch through RPC
|
2023-11-10 12:16:39 +01:00 |
|
ieQu1
|
8dc8237331
|
feat(ds): Introduce emqx_ds behavior
|
2023-11-10 12:16:39 +01:00 |
|
Thales Macedo Garitezi
|
42536bb5f7
|
chore(ds): avoid using records in persistence / rpc
Fixes https://emqx.atlassian.net/browse/EMQX-11279
|
2023-11-09 12:00:25 -03:00 |
|
ieQu1
|
a1cdbaa76d
|
fix(ds): Address code review remarks
|
2023-11-08 04:31:27 +01:00 |
|
ieQu1
|
c030188eb7
|
chore(ds): Add rebar.config file to app/emqx_durable_storage
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
7cb0322856
|
fix(emqx): Move bpapi and emqx message record to emqx_utils app
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
74cb43f8b1
|
fix(ds): Add unique ID to the key
|
2023-11-08 03:04:19 +01:00 |
|
Andrew Mayorov
|
54951c273f
|
feat(ds): mix safe cutoff into keymapper filter during iteration
|
2023-11-08 03:04:19 +01:00 |
|
Andrew Mayorov
|
7a94db25c3
|
fix(ds): don't iterate over incomplete epoch in bitmask lts storage
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
38b7f516bc
|
fix(ds): Change the directory where message database is stored
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
8e5dda40be
|
fix(ds): Fix static checks
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
99329e1243
|
refactor(ds): Address review remarks
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
2de79dd9ac
|
feat(ds): Replay QoS1 messages
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
e745e42093
|
test(ds): Explore full range of keys when testing ratchet function
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
87689890ff
|
chore(ds): Fix linter and compilation warnings
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
ef46c09caf
|
feat(ds): Implement ratchet function for bitmask keymapper
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
164ae9e94a
|
feat(ds): LTS bitfield storage passes all tests
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
56b6b176c2
|
fix(ds): LTS shall keeps the concrete topic indexes
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
7428e7037b
|
feat(ds): Bitfield + Learned Topic Structure
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
ac91dbc58f
|
feat(ds): Restore LTS trie from a dump
|
2023-11-08 03:04:19 +01:00 |
|
ieQu1
|
f1ab7c8a7c
|
feat(ds): Add persist callback to LTS trie
|
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
|
51a6f623fd
|
refactor(ds): Split out bitfield keymapper to a different module
|
2023-11-08 03:04:19 +01:00 |
|
Thales Macedo Garitezi
|
903b3863d1
|
chore(ps_ds): make persistent session module use new `emqx_ds` APIs
|
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 |