refactor(tdengine): move tdengine bridge into its own app

This commit is contained in:
firest 2023-05-10 14:05:35 +08:00
parent 954eef8f39
commit 0f979b3d24
15 changed files with 27 additions and 18 deletions

View File

@ -0,0 +1,2 @@
toxiproxy
tdengine

View File

@ -0,0 +1,8 @@
{erl_opts, [debug_info]}.
{deps, [
{tdengine, {git, "https://github.com/emqx/tdengine-client-erl", {tag, "0.1.6"}}},
{emqx_connector, {path, "../../apps/emqx_connector"}},
{emqx_resource, {path, "../../apps/emqx_resource"}},
{emqx_bridge, {path, "../../apps/emqx_bridge"}}
]}.

View File

@ -1,8 +1,8 @@
{application, emqx_bridge_tdengine, [
{description, "EMQX Enterprise TDEngine Bridge"},
{vsn, "0.1.0"},
{vsn, "0.1.1"},
{registered, []},
{applications, [kernel, stdlib]},
{applications, [kernel, stdlib, tdengine]},
{env, []},
{modules, []},
{links, []}

View File

@ -1,7 +1,7 @@
%%--------------------------------------------------------------------
%% Copyright (c) 2023 EMQ Technologies Co., Ltd. All Rights Reserved.
%%--------------------------------------------------------------------
-module(emqx_ee_bridge_tdengine).
-module(emqx_bridge_tdengine).
-include_lib("typerefl/include/types.hrl").
-include_lib("hocon/include/hoconsc.hrl").
@ -81,7 +81,8 @@ fields("config") ->
binary(),
#{desc => ?DESC("local_topic"), default => undefined}
)}
] ++ emqx_resource_schema:fields("resource_opts") ++ emqx_ee_connector_tdengine:fields(config);
] ++ emqx_resource_schema:fields("resource_opts") ++
emqx_bridge_tdengine_connector:fields(config);
fields("post") ->
[type_field(), name_field() | fields("config")];
fields("put") ->

View File

@ -2,7 +2,7 @@
%% Copyright (c) 2023 EMQ Technologies Co., Ltd. All Rights Reserved.
%%--------------------------------------------------------------------
-module(emqx_ee_connector_tdengine).
-module(emqx_bridge_tdengine_connector).
-behaviour(emqx_resource).

View File

@ -2,7 +2,7 @@
%% Copyright (c) 2022-2023 EMQ Technologies Co., Ltd. All Rights Reserved.
%%--------------------------------------------------------------------
-module(emqx_ee_bridge_tdengine_SUITE).
-module(emqx_bridge_tdengine_SUITE).
-compile(nowarn_export_all).
-compile(export_all).

View File

@ -6,6 +6,5 @@ mysql
redis
redis_cluster
pgsql
tdengine
clickhouse
dynamo

View File

@ -14,7 +14,8 @@
emqx_bridge_pulsar,
emqx_bridge_sqlserver,
emqx_bridge_rocketmq,
emqx_bridge_rabbitmq
emqx_bridge_rabbitmq,
emqx_bridge_tdengine
]},
{env, []},
{modules, []},

View File

@ -31,7 +31,7 @@ api_schemas(Method) ->
ref(emqx_ee_bridge_redis, Method ++ "_cluster"),
ref(emqx_ee_bridge_timescale, Method),
ref(emqx_ee_bridge_matrix, Method),
ref(emqx_ee_bridge_tdengine, Method),
ref(emqx_bridge_tdengine, Method),
ref(emqx_ee_bridge_clickhouse, Method),
ref(emqx_ee_bridge_dynamo, Method),
ref(emqx_bridge_rocketmq, Method),
@ -56,7 +56,7 @@ schema_modules() ->
emqx_ee_bridge_pgsql,
emqx_ee_bridge_timescale,
emqx_ee_bridge_matrix,
emqx_ee_bridge_tdengine,
emqx_bridge_tdengine,
emqx_ee_bridge_clickhouse,
emqx_ee_bridge_dynamo,
emqx_bridge_rocketmq,
@ -100,7 +100,7 @@ resource_type(redis_cluster) -> emqx_ee_connector_redis;
resource_type(pgsql) -> emqx_connector_pgsql;
resource_type(timescale) -> emqx_connector_pgsql;
resource_type(matrix) -> emqx_connector_pgsql;
resource_type(tdengine) -> emqx_ee_connector_tdengine;
resource_type(tdengine) -> emqx_bridge_tdengine_connector;
resource_type(clickhouse) -> emqx_ee_connector_clickhouse;
resource_type(dynamo) -> emqx_ee_connector_dynamo;
resource_type(rocketmq) -> emqx_bridge_rocketmq_connector;
@ -139,7 +139,7 @@ fields(bridges) ->
)},
{tdengine,
mk(
hoconsc:map(name, ref(emqx_ee_bridge_tdengine, "config")),
hoconsc:map(name, ref(emqx_bridge_tdengine, "config")),
#{
desc => <<"TDengine Bridge Config">>,
required => false

View File

@ -2,7 +2,6 @@
{deps, [
{hstreamdb_erl, {git, "https://github.com/hstreamdb/hstreamdb_erl.git", {tag, "0.2.5"}}},
{influxdb, {git, "https://github.com/emqx/influxdb-client-erl", {tag, "1.1.9"}}},
{tdengine, {git, "https://github.com/emqx/tdengine-client-erl", {tag, "0.1.6"}}},
{clickhouse, {git, "https://github.com/emqx/clickhouse-client-erl", {tag, "0.3"}}},
{erlcloud, {git, "https://github.com/emqx/erlcloud.git", {tag,"3.5.16-emqx-1"}}},
{emqx, {path, "../../apps/emqx"}},

View File

@ -8,7 +8,6 @@
ecpool,
hstreamdb_erl,
influxdb,
tdengine,
clickhouse,
erlcloud
]},

View File

@ -1,4 +1,4 @@
emqx_ee_bridge_tdengine {
emqx_bridge_tdengine {
config_enable.desc:
"""Enable or disable this bridge"""

View File

@ -1,4 +1,4 @@
emqx_ee_connector_tdengine {
emqx_bridge_tdengine_connector {
server.desc:
"""The IPv4 or IPv6 address or the hostname to connect to.<br/>

View File

@ -1,4 +1,4 @@
emqx_ee_bridge_tdengine {
emqx_bridge_tdengine {
config_enable.desc:
"""启用/禁用桥接"""

View File

@ -1,4 +1,4 @@
emqx_ee_connector_tdengine {
emqx_bridge_tdengine_connector {
server.desc:
"""将要连接的 IPv4 或 IPv6 地址,或者主机名。<br/>