From eb5956316a39ffb7c39a957005e4660f667f530d Mon Sep 17 00:00:00 2001 From: DDDHuang <44492639+DDDHuang@users.noreply.github.com> Date: Tue, 17 May 2022 11:27:55 +0800 Subject: [PATCH] fix(emqx_rule_engine): export func for rpc --- apps/emqx_rule_engine/src/emqx_rule_engine.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl index 53bd4c1b6..c3f9728bd 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl @@ -57,6 +57,9 @@ -export([ restore_action_metrics/2 ]). +-export([ fetch_resource_status/3 + ]). + -type(rule() :: #rule{}). -type(action() :: #action{}). -type(resource() :: #resource{}). @@ -407,7 +410,7 @@ is_source_alive(Nodes, ResId, _Opts = #{fetch := false}) -> end. %% fetch_resource_status -> #{is_alive => boolean()} -%% get_resource_status -> {ok #{is_alive => boolean()}} +%% get_resource_status -> {ok, #{is_alive => boolean()}} is_source_alive_([]) -> true; is_source_alive_([#{is_alive := true} | ResL]) -> is_source_alive_(ResL); is_source_alive_([{ok, #{is_alive := true}} | ResL]) -> is_source_alive_(ResL);