fix: set resource status disconnected

This commit is contained in:
EMQ-YangM 2022-04-29 16:37:04 +08:00
parent 7bbed713f4
commit 1bf33f75cc
2 changed files with 28 additions and 2 deletions

View File

@ -98,7 +98,7 @@ health_check_timeout_checker(Pid, Name, SleepTime, Timeout) ->
#{name => Name}, #{name => Name},
<<Name/binary, " health check timeout">> <<Name/binary, " health check timeout">>
), ),
emqx_resource:set_resource_status_connecting(Name), _ = emqx_resouce_instance:set_resource_status(Name, disconnected),
receive receive
health_check_finish -> timer:sleep(SleepTime) health_check_finish -> timer:sleep(SleepTime)
end end

View File

@ -19,6 +19,7 @@
-include("emqx_resource.hrl"). -include("emqx_resource.hrl").
-include("emqx_resource_utils.hrl"). -include("emqx_resource_utils.hrl").
-include_lib("emqx/include/logger.hrl").
-export([start_link/2]). -export([start_link/2]).
@ -28,7 +29,8 @@
get_metrics/1, get_metrics/1,
reset_metrics/1, reset_metrics/1,
list_all/0, list_all/0,
list_group/1 list_group/1,
set_resource_status/2
]). ]).
-export([ -export([
@ -339,6 +341,30 @@ do_set_resource_status_connecting(InstId) ->
{error, Error} {error, Error}
end. end.
-spec set_resource_status(instance_id(), resource_connection_status()) -> ok | {error, term()}.
set_resource_status(InstId, Status) ->
case lookup(InstId) of
{ok, Group, #{id := _} = Data} ->
?SLOG(
error,
#{
msg => "health check failed: timeout",
resource_id => InstId
}
),
update_resource(InstId, Group, Data#{status => Status});
Error ->
?SLOG(
error,
#{
msg => "set resource status field",
resource_id => InstId,
reason => Error
}
),
Error
end.
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------
%% internal functions %% internal functions
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------