46877e979b
chore: update copyright-year
2024-02-23 08:21:06 +01:00
b07df487f0
feat(modules): manage mria tables explicitly during startup
2024-02-13 20:36:22 +01:00
e9c8446d57
feat: upgrade erlfmt to support maybe syntax
2024-01-31 20:06:49 +08:00
c4dd083fd9
fix(delayed): delete delayed messge on all nodes
2024-01-11 14:12:30 +08:00
9ce96bafa3
feat: support to delete delayed messages via topic name
2024-01-09 15:06:06 +08:00
a3f33cc8bc
chore: fix typos in code and suite
2023-12-29 09:07:51 +08:00
423b586c56
fix(dialyzer): fix some dialyzer issues found on otp 26
2023-12-06 20:32:49 +01:00
f988de4ff4
feat(purge): clear delayed messages
2023-08-28 10:23:21 -03:00
b08102269a
refactor(calendar): refactor datetime-related code and remove redundant
2023-08-16 10:55:46 +08:00
e4d09d4ad4
feat: implement configuration and user data export/import CLI
...
Closes: EMQX-9203
2023-06-09 14:11:47 +03:00
c0b15c402b
test: add test for delayed update
2023-05-31 08:17:29 +08:00
9c11bfce80
refactor: rename emqx_misc to emqx_utils
2023-04-14 13:41:27 +02:00
dbc10c2eed
chore: update copyright year 2023
2023-01-02 09:22:27 +01:00
edb35c08a8
chore: refactor ms2qs function type
2022-11-24 20:14:33 +01:00
b9c5a5f822
fix(delayed): return correct node name
2022-11-24 20:14:33 +01:00
1fe9c105aa
refactor(mgmt): smplify the node_query/cluster_query implementation
2022-11-24 20:14:33 +01:00
08121e7df6
fix(mgmt): optimize the speed of query tail pages
...
In the previous, when you query the tail pages, all the front of rows
will be queried out and formatted. It greatly hurts the speed of query.
Currently, we only format the final result rows. i.e, the query for the
last page of data will be 10x faster.
2022-11-24 20:14:33 +01:00
dd7d4224ce
feat(delayed): check if the source client is banned when publishing a delayed message
2022-11-08 16:32:24 +08:00
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
bdaadda479
fix(banned): fix nit code
2022-10-18 13:39:48 +08:00
69701ff578
feat(banned): clean retained/delayed data when client is banned
2022-10-18 13:35:09 +08:00
6836a502ac
fix(delayed): Improve time precision of delayed messages
...
Use milliseconds internally in emqx_delayed to store the publish time, improving precision
2022-09-27 13:24:54 +08:00
8521d8dac5
fix(time): replace os:system_time with erlang:system_time
...
Avoid the problem of inaccurate timers caused by mixing erlang:system_time/0-1
and os:system_time/0-1
2022-09-08 16:13:05 +08:00
39b1b20506
feat: fix the hook priorities
2022-06-15 19:03:40 +08:00
590a87a72b
fix: the delayed module is disbled after ./bin/emqx stop
2022-06-15 12:00:41 +08:00
8aa60cc0a5
feat: generate a minimized emqx.conf
2022-05-31 19:20:27 +08:00
9e706fc76d
feat(telemetry): count advanced mqtt feature usage
...
Originally, we wanted to just check if certain features were enabled.
Now, we want to count certain usage metrics for them.
2022-05-11 15:15:17 -03:00
fc391c7b9e
fix(delayed): unify and optimize the enable/disable codes
2022-04-26 15:26:40 +08:00
ce437ac5b2
chore(emqx_modules): improve emqx_delayed coverage
2022-03-31 20:29:46 +03:00
4d3157743e
style: format `emqx_modules`
2022-03-22 09:31:55 -03:00
d231b2222e
Merge pull request #7328 from lafirest/fix/delayed_lookup
...
fix(delayed): make it possible to lookup/delete other node's delayed …
2022-03-18 00:53:53 +08:00
3fc4236565
fix(delayed): make it possible to lookup/delete other node's delayed message
2022-03-17 14:36:55 +08:00
43a935286a
fix(delayed): cancel the publish timer when terminate
2022-03-16 17:51:29 +08:00
1a8288de75
fix(delayed): fix code style error
2022-03-11 11:32:25 +08:00
eeb92dae23
fix(delayed): fix that the query is not a cluster query
2022-03-11 10:54:11 +08:00
2053d21bd5
fix(emqx_delayed): fix config update not working
2022-02-25 11:24:30 +08:00
63167cea70
chore: update copyright
2022-01-05 20:55:00 +01:00
2898fa76e1
Merge remote-tracking branch 'origin/release-5.0-beta.3' into merge-5.0-beta.3-to-master
2022-01-03 11:39:06 +01:00
54ea7a5871
Merge pull request #6582 from DDDHuang/config_bugfix
...
fix(config): update configs in cluster
2021-12-31 16:03:41 +08:00
d18a2ab57c
fix(delayed): base64 encode twice
2021-12-31 14:07:34 +08:00
23cf74d829
fix(delayed): update config in cluster
2021-12-31 12:46:29 +08:00
ca2660d609
chore: refactor ?SLOG
2021-12-18 00:17:45 +01:00
4a07d5e1f3
refactor(paginate): use exported fun call `{M,F}`
2021-10-26 16:16:37 +08:00
d784e63b9f
emqx_conf ( #5939 )
...
* feat(emqx_conf): move conf manager for emqx_machine to emqx_conf
* chore(emqx_conf): change emqx:get_config/2 to emqx_conf:get/2
* fix: common test failed
* fix: badmatch by typo wrong key
* fix(emqx_conf): get the wrong core nodes
* fix(emqx_conf): get core node's tnx_id not latest tnx_id
* fix: add ro_transation when copy conf file
* fix: delete debug info
* fix: change ekka_rlog to mria_rlog
* fix: remove cluster_rpc from emqx_machine.
* fix: don't call ekka:start/0 explicitly
* fix: ekka should be start in emqx_machine
2021-10-21 18:08:51 +08:00
326923850c
chore(mria): Get rid of copy_mnesia callback
2021-10-18 22:04:05 +02:00
9965d6e028
chore(mria): ekka_mnesia:create_table -> mria:create_table
2021-10-18 22:04:05 +02:00
b515a45a4f
chore(mria): Rename module: ekka_mnesia -> mria
2021-10-18 22:04:05 +02:00
8d11a61999
fix(delayed): delete with worong msgid return 200.
2021-09-23 16:23:30 +08:00
5baf427b75
fix(delayed): default username when get delayed message form `/publish` api.
2021-09-22 18:45:18 +08:00
da923c7df0
fix(delayed): `max-delayed-messages` increase 1 than setting.
2021-09-22 18:45:18 +08:00
Zaiming (Stone) Shi