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

fix(emqx_rule_engine): export func for rpc

This commit is contained in:
DDDHuang 2022-05-17 11:27:55 +08:00
parent 86e8de4737
commit eb5956316a
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/emqx_rule_engine/src/emqx_rule_engine.erl
View File

@ -57,6 +57,9 @@
-export([ restore_action_metrics/2 -export([ restore_action_metrics/2
]). ]).
-export([ fetch_resource_status/3
]).
-type(rule() :: #rule{}). -type(rule() :: #rule{}).
-type(action() :: #action{}). -type(action() :: #action{}).
-type(resource() :: #resource{}). -type(resource() :: #resource{}).
@ -407,7 +410,7 @@ is_source_alive(Nodes, ResId, _Opts = #{fetch := false}) ->
end. end.
%% fetch_resource_status -> #{is_alive => boolean()} %% 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_([]) -> true;
is_source_alive_([#{is_alive := true} | ResL]) -> is_source_alive_(ResL); is_source_alive_([#{is_alive := true} | ResL]) -> is_source_alive_(ResL);
is_source_alive_([{ok, #{is_alive := true}} | ResL]) -> is_source_alive_(ResL); is_source_alive_([{ok, #{is_alive := true}} | ResL]) -> is_source_alive_(ResL);