diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl index 69b755cea..597daa378 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl @@ -196,6 +196,7 @@ maybe_add_metrics_for_rule(Id) -> clear_metrics_for_rule(Id) -> ok = emqx_plugin_libs_metrics:clear_metrics(rule_metrics, Id). +-spec(reset_metrics_for_rule(rule_id()) -> ok). reset_metrics_for_rule(Id) -> emqx_plugin_libs_metrics:reset_metrics(rule_metrics, Id). diff --git a/apps/emqx_rule_engine/src/proto/emqx_rule_engine_proto_v1.erl b/apps/emqx_rule_engine/src/proto/emqx_rule_engine_proto_v1.erl index c916f45a7..cc3a79a74 100644 --- a/apps/emqx_rule_engine/src/proto/emqx_rule_engine_proto_v1.erl +++ b/apps/emqx_rule_engine/src/proto/emqx_rule_engine_proto_v1.erl @@ -29,7 +29,7 @@ introduced_in() -> "5.0.0". --spec reset_metrics(emqx_rule_engine:rule_id()) -> +-spec reset_metrics(rule_id()) -> emqx_cluster_rpc:multicall_return(ok). reset_metrics(RuleId) -> emqx_cluster_rpc:multicall(emqx_rule_engine, reset_metrics_for_rule, [RuleId]).