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

fix(greptimedb): add sync_start to avoid false negative healthy check 

Fixes https://emqx.atlassian.net/browse/EMQX-10709
This commit is contained in:
Paulo Zulato 2023-08-02 18:27:33 -03:00
parent 97fdc834de
commit 2c63fe3bcd
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,6 @@
{application, emqx_bridge_greptimedb, [ {application, emqx_bridge_greptimedb, [
{description, "EMQX GreptimeDB Bridge"}, {description, "EMQX GreptimeDB Bridge"},
{vsn, "0.1.0"}, {vsn, "0.1.1"},
{registered, []}, {registered, []},
{applications, [ {applications, [
kernel, kernel,

9
apps/emqx_bridge_greptimedb/src/emqx_bridge_greptimedb_connector.erl
View File

@ -53,6 +53,8 @@
-define(AUTO_RECONNECT_S, 1). -define(AUTO_RECONNECT_S, 1).
-define(CONNECT_TIMEOUT, 5_000).
%% ------------------------------------------------------------------------------------------------- %% -------------------------------------------------------------------------------------------------
%% resource callback %% resource callback
callback_mode() -> always_sync. callback_mode() -> always_sync.
@ -251,6 +253,12 @@ do_start_client(
{error, Reason} {error, Reason}
end. end.
grpc_config() ->
#{
sync_start => true,
connect_timeout => ?CONNECT_TIMEOUT
}.
client_config( client_config(
InstId, InstId,
Config = #{ Config = #{
@ -264,6 +272,7 @@ client_config(
{pool, InstId}, {pool, InstId},
{pool_type, random}, {pool_type, random},
{auto_reconnect, ?AUTO_RECONNECT_S}, {auto_reconnect, ?AUTO_RECONNECT_S},
{gprc_options, grpc_config()},
{timeunit, maps:get(precision, Config, ms)} {timeunit, maps:get(precision, Config, ms)}
] ++ protocol_config(Config). ] ++ protocol_config(Config).