lafirest
1a1415a996
fix(emqx_slow_subs): fix upgrade action error
2022-02-18 16:27:22 +08:00
lafirest
8a75b53052
fix(emqx_slow_subs): add upgrade/downgrade action
2022-02-18 14:32:45 +08:00
lafirest
252514bfe0
fix(emqx_slow_subs): trap the exit message
2022-02-08 18:28:00 +08:00
lafirest
1f718fbb94
fix(emqx_slow_subs): fix index update error
2022-01-24 18:16:29 +08:00
firest
5ec3b6aef7
fix(emqx_slow_subs): add default for stats_type
2022-01-21 16:25:06 +08:00
lafirest
14636a745e
fix(emqx_slow_subs_api): return error when the module is not enable
2022-01-19 16:11:11 +08:00
lafirest
46f86204c0
fix(emqx_slow_subs): add ClientInfo into the args of the delivery.completed hook
2022-01-19 14:02:30 +08:00
lafirest
696acbfc5c
fix(emqx_slow_subs): change on_publish_completed to on_delivery_completed
2022-01-19 09:50:31 +08:00
lafirest
44fe882f14
refactor(emqx_slow_subs): refactor slow subs
2022-01-19 09:50:31 +08:00
lafirest
e651becd99
fix(emqx_slow_subs): fix threshold related bugs
...
1. limit the interval between calling hooks
2. improve the code of update threshold
2021-12-08 15:05:39 +08:00
lafirest
8dd4d88d5b
fix(emx_slow_updates): fix the error of topk update ( #6312 )
2021-11-26 14:57:25 +08:00
lafirest
fef3fc27cb
refactor(emqx_slow_subs): refactor use moving average ( #6287 )
...
* refactor(emqx_slow_subs): refactor use moving average
* fix(emqx_slow_subs): change elapsed to latency, and fix some error
* fix(emqx_slow_subs): fix emqx_mgmt_api.erl indent
* fix(emqx_slow_subs): change api name
* fix(emqx_slow_subs): fix and improve some code
* fix(emqx_slow_subs): move clienid filed from latency_stats to session
2021-11-26 10:42:15 +08:00