yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(emqx_slow_subs): add default for stats_type

This commit is contained in:
firest 2022-01-21 16:25:06 +08:00
parent 64a1466af5
commit 5ec3b6aef7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_plugin_libs/src/emqx_slow_subs/emqx_slow_subs.erl
View File

@ -46,7 +46,7 @@
-type message() :: #message{}. -type message() :: #message{}.
-import(proplists, [get_value/2]). -import(proplists, [get_value/2, get_value/3]).
-type stats_type() :: whole %% whole = internal + response -type stats_type() :: whole %% whole = internal + response
| internal %% timespan from message in to deliver | internal %% timespan from message in to deliver
@ -190,7 +190,7 @@ expire_tick(_) ->
load(Cfg) -> load(Cfg) ->
MaxSize = get_value(top_k_num, Cfg), MaxSize = get_value(top_k_num, Cfg),
StatsType = get_value(stats_type, Cfg), StatsType = get_value(stats_type, Cfg, whole),
Threshold = get_value(threshold, Cfg), Threshold = get_value(threshold, Cfg),
_ = emqx:hook('delivery.completed', _ = emqx:hook('delivery.completed',
fun ?MODULE:on_delivery_completed/4, fun ?MODULE:on_delivery_completed/4,