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

Merge pull request #13139 from zhongwencool/influxdb-client-failed-msg-port 

chore: improved InfluxDB connection error messaging
This commit is contained in:
zhongwencool 2024-05-30 10:57:21 +08:00 committed by GitHub
parent c54d25de98 7d9333a9d7
commit 8ab7e75e64
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_influxdb/src/emqx_bridge_influxdb.app.src
View File

@ -1,6 +1,6 @@
{application, emqx_bridge_influxdb, [ {application, emqx_bridge_influxdb, [
{description, "EMQX Enterprise InfluxDB Bridge"}, {description, "EMQX Enterprise InfluxDB Bridge"},
{vsn, "0.2.1"}, {vsn, "0.2.2"},
{registered, []}, {registered, []},
{applications, [ {applications, [
kernel, kernel,

4
apps/emqx_bridge_influxdb/src/emqx_bridge_influxdb_connector.erl
View File

@ -396,7 +396,7 @@ do_start_client(InstId, ClientConfig, Config) ->
}), }),
%% no leak %% no leak
_ = influxdb:stop_client(Client), _ = influxdb:stop_client(Client),
{error, influxdb_client_auth_error} {error, connect_ok_but_auth_failed}
end; end;
{false, Reason} -> {false, Reason} ->
?tp(influxdb_connector_start_failed, #{ ?tp(influxdb_connector_start_failed, #{
@ -410,7 +410,7 @@ do_start_client(InstId, ClientConfig, Config) ->
}), }),
%% no leak %% no leak
_ = influxdb:stop_client(Client), _ = influxdb:stop_client(Client),
{error, influxdb_client_not_alive} {error, {connect_failed, Reason}}
end; end;
{error, {already_started, Client0}} -> {error, {already_started, Client0}} ->
?tp(influxdb_connector_start_already_started, #{}), ?tp(influxdb_connector_start_already_started, #{}),