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

fix: change rule_speed record type

This commit is contained in:
EMQ-YangM 2022-04-07 09:50:31 +08:00
parent 299c369d80
commit 0e02e8df9d
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx_rule_engine/src/emqx_rule_metrics.erl
View File

@ -92,14 +92,14 @@
-define(SAMPCOUNT_5M, (?SECS_5M div ?SAMPLING)). -define(SAMPCOUNT_5M, (?SECS_5M div ?SAMPLING)).
-record(rule_speed, { -record(rule_speed, {
max = 0 :: number(), max = 0.0 :: float(),
current = 0 :: number(), current = 0.0 :: float(),
last5m = 0 :: number(), last5m = 0.0 :: float(),
%% metadata for calculating the avg speed %% metadata for calculating the avg speed
tick = 1 :: number(), tick = 1 :: integer(),
last_v = 0 :: number(), last_v = 0 :: integer(),
%% metadata for calculating the 5min avg speed %% metadata for calculating the 5min avg speed
last5m_acc = 0 :: number(), last5m_acc = 0.0 :: float(),
last5m_smpl = [] :: list() last5m_smpl = [] :: list()
}). }).

2
apps/emqx_rule_engine/test/emqx_rule_engine_SUITE.erl
View File

@ -377,7 +377,7 @@ t_reset_metrics(_Config) ->
emqx_rule_metrics:reset_metrics(Id), emqx_rule_metrics:reset_metrics(Id),
?assertEqual(#{exception => 0,failed => 0, ?assertEqual(#{exception => 0,failed => 0,
matched => 0,no_result => 0,passed => 0, matched => 0,no_result => 0,passed => 0,
speed => 0.0,speed_last5m => 0.0,speed_max => 0}, speed => 0.0,speed_last5m => 0.0,speed_max => 0.0},
emqx_rule_metrics:get_rule_metrics(Id)), emqx_rule_metrics:get_rule_metrics(Id)),
?assertEqual(#{failed => 0,success => 0,taken => 0}, ?assertEqual(#{failed => 0,success => 0,taken => 0},
emqx_rule_metrics:get_action_metrics(ResId)), emqx_rule_metrics:get_action_metrics(ResId)),