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

refactor(emqx_resource_instance): add function create_default_checker

This commit is contained in:
EMQ-YangM 2022-02-07 17:48:26 +08:00
parent 8976e25b7a
commit 3b3f3fed76
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
apps/emqx_resource/src/emqx_resource_instance.erl
View File

@ -248,20 +248,21 @@ start_and_check(InstId, ResourceType, Config, Opts, Data) ->
ets:insert(emqx_resource_instance, {InstId, Data2}), ets:insert(emqx_resource_instance, {InstId, Data2}),
case maps:get(async_create, Opts, false) of case maps:get(async_create, Opts, false) of
false -> case do_health_check(Data2) of false -> case do_health_check(Data2) of
ok -> emqx_resource_health_check:create_checker(InstId, ok -> create_default_checker(InstId, Opts);
maps:get(health_check_interval, Opts, 15000),
maps:get(health_check_timeout, Opts, 10000));
{error, Reason} -> {error, Reason} {error, Reason} -> {error, Reason}
end; end;
true -> emqx_resource_health_check:create_checker(InstId, true -> create_default_checker(InstId, Opts)
maps:get(health_check_interval, Opts, 15000),
maps:get(health_check_timeout, Opts, 10000))
end; end;
{error, Reason} -> {error, Reason} ->
ets:insert(emqx_resource_instance, {InstId, Data#{status => stopped}}), ets:insert(emqx_resource_instance, {InstId, Data#{status => stopped}}),
{error, Reason} {error, Reason}
end. end.
create_default_checker(InstId, Opts) ->
emqx_resource_health_check:create_checker(InstId,
maps:get(health_check_interval, Opts, 15000),
maps:get(health_check_timeout, Opts, 10000)).
do_stop(InstId) when is_binary(InstId) -> do_stop(InstId) when is_binary(InstId) ->
do_with_instance_data(InstId, fun do_stop/1, []); do_with_instance_data(InstId, fun do_stop/1, []);
do_stop(#{state := undefined}) -> do_stop(#{state := undefined}) ->