From 1c32b08b21c3a11369853dcc820d555212676fb8 Mon Sep 17 00:00:00 2001
From: EMQ-YangM <yangm@emqx.io>
Date: Thu, 7 Apr 2022 10:32:58 +0800
Subject: [PATCH] feat: impl reset cluster metrics

---
 apps/emqx_rule_engine/src/emqx_rule_engine_api.erl | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl b/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl
index b2766e0e0..a6220ee9f 100644
--- a/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl
+++ b/apps/emqx_rule_engine/src/emqx_rule_engine_api.erl
@@ -162,6 +162,7 @@
         , show_rule/2
         , delete_rule/2
         , reset_metrics/2
+        , reset_metrics_local/1
         ]).
 
 -export([ list_actions/2
@@ -260,8 +261,10 @@ delete_rule(#{id := Id}, _Params) ->
     ok = emqx_rule_engine:delete_rule(Id),
     return(ok).
 
+reset_metrics_local(Id) -> emqx_rule_metrics:reset_metrics(Id).
+
 reset_metrics(#{id := Id}, _Params) ->
-    ok = emqx_rule_metrics:reset_metrics(Id),
+    _ = ?CLUSTER_CALL(reset_metrics_local, [Id]),
     return(ok).
 
 %%------------------------------------------------------------------------------