zmstone
213e4785e7
Merge remote-tracking branch 'origin/release-57' into 0619-sync-release-57-to-master
2024-06-19 14:54:48 +02:00
Serge Tupchii
60882a616e
fix(data_backup): re-index retained messages after importing
2024-06-18 17:31:19 +03:00
Ilya Averyanov
1a664c941b
chore(retainer): scan table in batches, improve stream usage
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2024-05-16 16:06:11 +03:00
Ilya Averyanov
552b62236c
chore(retainer): move filter/foreach to emqx_utils_stream
2024-05-15 19:09:06 +03:00
Ilya Averyanov
0b39aaadbd
chore(retainer): get rid of qlc usage
2024-05-15 19:09:06 +03:00
Ilya Averyanov
57287f0722
fix(retainer): fix qlc cursor cleanup
2024-05-08 21:38:37 +03:00
Shawn
9d1a69aaa9
fix: cannot import retained messages
2024-04-07 17:03:14 +08:00
Ilya Averyanov
dfdf7455d3
feat(retainer): make additional implementations pluggable
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2024-02-28 18:43:17 +03:00
Ilya Averyanov
d94066a10a
chore(retainer): refactor types; remove hotwiring to builtin config
2024-02-28 18:43:16 +03:00
Ilya Averyanov
aa2ee9c409
chore(retainer): add backend creation to the behaviour
2024-02-28 18:43:16 +03:00
Zaiming (Stone) Shi
46877e979b
chore: update copyright-year
2024-02-23 08:21:06 +01:00
Ilya Averyanov
4c66a1135b
Merge pull request #12303 from savonarola/0111-fix-indexing
...
fix(retainer): fix topic search by index
2024-01-11 18:44:56 +02:00
Ilya Averyanov
09d524144b
fix(retainer): fix topic search by index
2024-01-11 16:00:58 +03:00
firest
f896cf2f4f
fix(retain): add `hasnext` into the meta data for the `GET /retain/messages`
2024-01-11 16:14:40 +08:00
Andrew Mayorov
534a741b0e
perf(retainer): do not GC on replicant nodes
2023-08-03 15:34:24 +04:00
Andrew Mayorov
42be694d40
perf(retainer): squash index updates into single dirty activity
...
In order to minimize number of round trips to core nodes and between
them, improving publishing latency. This shouldn't make consistency
worse than it was before.
2023-08-03 12:51:36 +04:00
firest
1202bef6db
fix(emqx_retainer): wait for Mria tables
2023-06-29 03:16:05 +00:00
ieQu1
e3595f2e79
chore(mria): Bump version to 0.4.0
2023-03-11 00:37:25 +01:00
Thales Macedo Garitezi
51ad27cb4b
test(retainer): assert that retained messages are not lost when changing storage type
2023-01-04 13:52:52 -03:00
Zaiming (Stone) Shi
dbc10c2eed
chore: update copyright year 2023
2023-01-02 09:22:27 +01:00
Ilya Averyanov
7ae3ecfccb
chore(retainer): optimize index writes
2022-12-09 14:42:43 +03:00
firest
ebaba0c2b1
fix: Revert "feat(banned): clean retained/delayed data when client is banned"
...
This reverts commit 69701ff578
.
2022-11-08 11:36:11 +08:00
firest
69701ff578
feat(banned): clean retained/delayed data when client is banned
2022-10-18 13:35:09 +08:00
ieQu1
6f4d0e2ed5
refactor(retainer_mnesia): Export transactions
2022-08-22 19:52:37 +02:00
ieQu1
9ca2e3bc2a
feat(retainer): CLI to list and clean retained messages
2022-06-14 11:24:15 +02:00
Ilya Averyanov
9b61997dc0
feat(retainer): add topic indexing
2022-04-20 19:55:57 +03:00
firest
f1acfece6b
chore(retainer): reformat retainer codes
2022-04-19 10:41:54 +08:00
firest
5bf1d77993
refactor(emqx_retainer): use hierarchical limiter for the flow control
2022-02-24 18:06:40 +08:00
JianBo He
b1959086d9
chore: fix elvis warnings
2022-01-12 13:51:37 +08:00
JianBo He
6bb919b65c
chore(retainer): change root name emqx_retainer > retainer
2022-01-11 15:30:42 +08:00
zhongwencool
3bdfa183f3
Merge pull request #6666 from JimMoen/merge-5.0-beta.3-to-master
...
Merge 5.0 beta.3 to master
2022-01-06 18:20:30 +08:00
JimMoen
9a115b99a4
Merge remote-tracking branch 'emqx/release-5.0-beta.3' into merge-5.0-beta.3-to-master
2022-01-06 14:08:45 +08:00
Zaiming (Stone) Shi
63167cea70
chore: update copyright
2022-01-05 20:55:00 +01:00
lafirest
6a80f8320d
Merge pull request #6622 from lafirest/fix/retainer_stats
...
fix(emqx_retainer): fix the stats function of retainer
2022-01-05 09:42:38 +08:00
Zaiming (Stone) Shi
211b8e1b06
Merge remote-tracking branch 'origin/release-5.0-beta.3' into merge-5.0-beta.3-to-master
2022-01-04 22:48:25 +01:00
lafirest
a593921137
fix(emqx_retainer): fix the stats function of retainer
2022-01-04 17:26:48 +08:00
lafirest
aacdc5c2f7
fix(emqx_retainer): remove disc_only option
2022-01-04 14:40:11 +08:00
Spycsh
ca2660d609
chore: refactor ?SLOG
2021-12-18 00:17:45 +01:00
Zaiming Shi
ac693c0dcb
refactor(retainer): use ordered_set Mnesia table type
...
ordered_set is compatible to set in all the existing APIs
and in addition, it provides a more deterministic traversing
cursor in case we want to change the current dirty_select
based "select ALL" implementation
2021-11-16 12:33:59 +01:00
k32
37a1c45af0
fix(dialyzer): Fix problems found by dialyzer
2021-10-18 22:04:05 +02:00
k32
d14b8e7da9
chore(mria): ekka_rlog -> mria_rlog
2021-10-18 22:04:05 +02:00
k32
9965d6e028
chore(mria): ekka_mnesia:create_table -> mria:create_table
2021-10-18 22:04:05 +02:00
k32
ae2056da1b
chore(mria): Fix clear_table and ro_transaction calls
2021-10-18 22:04:05 +02:00
k32
b515a45a4f
chore(mria): Rename module: ekka_mnesia -> mria
2021-10-18 22:04:05 +02:00
lafirest
3524942766
fix: change all ~s in io format to ~ts
...
we should use unicode to replace latin1
2021-10-12 15:09:24 +08:00
k32
9c74fa42a5
chore(rlog): Use the new method of creating shards
2021-08-21 17:47:53 +02:00
lafirest
adc6226eae
refactor(emqx_retainer): emqx_retainer_api use openapi model
2021-08-19 10:12:08 +08:00
Shawn
e8e95d39ef
refactor(config): move emqx_config:get/get_raw to emqx:get_config/get_raw_config ( #5517 )
2021-08-18 14:52:57 +08:00
lafirest
6c73679b02
chore(emqx_retainer): simplified the retainer config
2021-08-10 17:47:30 +08:00
Zaiming Shi
5d59ac1f02
refactor(logging): delete log headers from all modules
2021-08-01 09:36:59 +02:00