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

fix(greptime): attempt patch for cleaning up channels when worker terminates

This commit is contained in:
Thales Macedo Garitezi 2024-06-18 17:52:26 -03:00
parent 9dd419d822
commit ffec1c7fe0
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_greptimedb/rebar.config
View File

@ -6,7 +6,7 @@
{emqx_connector, {path, "../../apps/emqx_connector"}}, {emqx_connector, {path, "../../apps/emqx_connector"}},
{emqx_resource, {path, "../../apps/emqx_resource"}}, {emqx_resource, {path, "../../apps/emqx_resource"}},
{emqx_bridge, {path, "../../apps/emqx_bridge"}}, {emqx_bridge, {path, "../../apps/emqx_bridge"}},
{greptimedb, {git, "https://github.com/GreptimeTeam/greptimedb-ingester-erl", {tag, "v0.1.8"}}} {greptimedb, {git, "https://github.com/thalesmg/greptimedb-ingester-erl", {tag, "v0.1.8.1"}}}
]}. ]}.
{plugins, [rebar3_path_deps]}. {plugins, [rebar3_path_deps]}.
{project_plugins, [erlfmt]}. {project_plugins, [erlfmt]}.

2
apps/emqx_bridge_greptimedb/test/emqx_bridge_greptimedb_SUITE.erl
View File

@ -99,6 +99,8 @@ init_per_group(GreptimedbType, Config0) when
#{work_dir => emqx_cth_suite:work_dir(Config0)} #{work_dir => emqx_cth_suite:work_dir(Config0)}
), ),
{ok, _Api} = emqx_common_test_http:create_default_app(), {ok, _Api} = emqx_common_test_http:create_default_app(),
%% fixme: debugging
emqx_logger:set_log_level(debug),
Config = [{use_tls, UseTLS} | Config0], Config = [{use_tls, UseTLS} | Config0],
{Name, ConfigString, GreptimedbConfig} = greptimedb_config( {Name, ConfigString, GreptimedbConfig} = greptimedb_config(
grpcv1, GreptimedbHost, GreptimedbPort, Config grpcv1, GreptimedbHost, GreptimedbPort, Config

3
mix.exs
View File

@ -218,8 +218,7 @@ defmodule EMQXUmbrella.MixProject do
{:snappyer, "1.2.9", override: true}, {:snappyer, "1.2.9", override: true},
{:crc32cer, "0.1.8", override: true}, {:crc32cer, "0.1.8", override: true},
{:opentsdb, github: "emqx/opentsdb-client-erl", tag: "v0.5.1", override: true}, {:opentsdb, github: "emqx/opentsdb-client-erl", tag: "v0.5.1", override: true},
{:greptimedb, {:greptimedb, github: "thalesmg/greptimedb-ingester-erl", tag: "v0.1.8.1", override: true},
github: "GreptimeTeam/greptimedb-ingester-erl", tag: "v0.1.8", override: true},
# The following two are dependencies of rabbit_common. They are needed here to # The following two are dependencies of rabbit_common. They are needed here to
# make mix not complain about conflicting versions # make mix not complain about conflicting versions
{:thoas, github: "emqx/thoas", tag: "v1.0.0", override: true}, {:thoas, github: "emqx/thoas", tag: "v1.0.0", override: true},