refactor(pgsql): move pgsql && matrix && timescale bridges into their own app

This commit is contained in:
firest 2023-05-10 16:51:33 +08:00
parent 594ceaf9e6
commit 066ed5c6ec
12 changed files with 43 additions and 21 deletions

View File

@ -0,0 +1,7 @@
{erl_opts, [debug_info]}.
{deps, [
{emqx_connector, {path, "../../apps/emqx_connector"}},
{emqx_resource, {path, "../../apps/emqx_resource"}},
{emqx_bridge, {path, "../../apps/emqx_bridge"}}
]}.

View File

@ -1,7 +1,7 @@
%%--------------------------------------------------------------------
%% Copyright (c) 2023 EMQ Technologies Co., Ltd. All Rights Reserved.
%%--------------------------------------------------------------------
-module(emqx_ee_bridge_matrix).
-module(emqx_bridge_matrix).
-export([
conn_bridge_examples/1
@ -22,7 +22,7 @@ conn_bridge_examples(Method) ->
#{
<<"matrix">> => #{
summary => <<"Matrix Bridge">>,
value => emqx_ee_bridge_pgsql:values(Method, matrix)
value => emqx_bridge_pgsql:values(Method, matrix)
}
}
].
@ -34,9 +34,9 @@ namespace() -> "bridge_matrix".
roots() -> [].
fields("post") ->
emqx_ee_bridge_pgsql:fields("post", matrix);
emqx_bridge_pgsql:fields("post", matrix);
fields(Method) ->
emqx_ee_bridge_pgsql:fields(Method).
emqx_bridge_pgsql:fields(Method).
desc(_) ->
undefined.

View File

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

View File

@ -0,0 +1,7 @@
{erl_opts, [debug_info]}.
{deps, [
{emqx_connector, {path, "../../apps/emqx_connector"}},
{emqx_resource, {path, "../../apps/emqx_resource"}},
{emqx_bridge, {path, "../../apps/emqx_bridge"}}
]}.

View File

@ -1,7 +1,7 @@
%%--------------------------------------------------------------------
%% Copyright (c) 2022 EMQ Technologies Co., Ltd. All Rights Reserved.
%% Copyright (c) 2022-2023 EMQ Technologies Co., Ltd. All Rights Reserved.
%%--------------------------------------------------------------------
-module(emqx_ee_bridge_pgsql).
-module(emqx_bridge_pgsql).
-include_lib("typerefl/include/types.hrl").
-include_lib("hocon/include/hoconsc.hrl").

View File

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

View File

@ -0,0 +1,7 @@
{erl_opts, [debug_info]}.
{deps, [
{emqx_connector, {path, "../../apps/emqx_connector"}},
{emqx_resource, {path, "../../apps/emqx_resource"}},
{emqx_bridge, {path, "../../apps/emqx_bridge"}}
]}.

View File

@ -1,7 +1,7 @@
%%--------------------------------------------------------------------
%% Copyright (c) 2023 EMQ Technologies Co., Ltd. All Rights Reserved.
%%--------------------------------------------------------------------
-module(emqx_ee_bridge_timescale).
-module(emqx_bridge_timescale).
-export([
conn_bridge_examples/1
@ -22,7 +22,7 @@ conn_bridge_examples(Method) ->
#{
<<"timescale">> => #{
summary => <<"Timescale Bridge">>,
value => emqx_ee_bridge_pgsql:values(Method, timescale)
value => emqx_bridge_pgsql:values(Method, timescale)
}
}
].
@ -34,9 +34,9 @@ namespace() -> "bridge_timescale".
roots() -> [].
fields("post") ->
emqx_ee_bridge_pgsql:fields("post", timescale);
emqx_bridge_pgsql:fields("post", timescale);
fields(Method) ->
emqx_ee_bridge_pgsql:fields(Method).
emqx_bridge_pgsql:fields(Method).
desc(_) ->
undefined.

View File

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

View File

@ -19,7 +19,7 @@ api_schemas(Method) ->
ref(emqx_bridge_kafka, Method ++ "_producer"),
ref(emqx_bridge_cassandra, Method),
ref(emqx_ee_bridge_mysql, Method),
ref(emqx_ee_bridge_pgsql, Method),
ref(emqx_bridge_pgsql, Method),
ref(emqx_ee_bridge_mongodb, Method ++ "_rs"),
ref(emqx_ee_bridge_mongodb, Method ++ "_sharded"),
ref(emqx_ee_bridge_mongodb, Method ++ "_single"),
@ -29,8 +29,8 @@ api_schemas(Method) ->
ref(emqx_ee_bridge_redis, Method ++ "_single"),
ref(emqx_ee_bridge_redis, Method ++ "_sentinel"),
ref(emqx_ee_bridge_redis, Method ++ "_cluster"),
ref(emqx_ee_bridge_timescale, Method),
ref(emqx_ee_bridge_matrix, Method),
ref(emqx_bridge_timescale, Method),
ref(emqx_bridge_matrix, Method),
ref(emqx_bridge_tdengine, Method),
ref(emqx_ee_bridge_clickhouse, Method),
ref(emqx_ee_bridge_dynamo, Method),
@ -53,9 +53,9 @@ schema_modules() ->
emqx_ee_bridge_mongodb,
emqx_ee_bridge_mysql,
emqx_ee_bridge_redis,
emqx_ee_bridge_pgsql,
emqx_ee_bridge_timescale,
emqx_ee_bridge_matrix,
emqx_bridge_pgsql,
emqx_bridge_timescale,
emqx_bridge_matrix,
emqx_bridge_tdengine,
emqx_ee_bridge_clickhouse,
emqx_ee_bridge_dynamo,
@ -280,7 +280,7 @@ pgsql_structs() ->
[
{Type,
mk(
hoconsc:map(name, ref(emqx_ee_bridge_pgsql, "config")),
hoconsc:map(name, ref(emqx_bridge_pgsql, "config")),
#{
desc => <<Name/binary, " Bridge Config">>,
required => false

View File

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

View File

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