refactor(clickhouse connector): to use emqx_connector_info
This commit refactors the clickhouse connector to use the `emqx_connector_info` behavior.
This commit is contained in:
parent
afa3da6d0d
commit
c6d7c57bbd
|
@ -8,7 +8,10 @@
|
||||||
emqx_resource,
|
emqx_resource,
|
||||||
clickhouse
|
clickhouse
|
||||||
]},
|
]},
|
||||||
{env, [{emqx_action_info_modules, [emqx_bridge_clickhouse_action_info]}]},
|
{env, [
|
||||||
|
{emqx_action_info_modules, [emqx_bridge_clickhouse_action_info]},
|
||||||
|
{emqx_connector_info_modules, [emqx_bridge_clickhouse_connector_info]}
|
||||||
|
]},
|
||||||
{modules, []},
|
{modules, []},
|
||||||
{links, []}
|
{links, []}
|
||||||
]}.
|
]}.
|
||||||
|
|
|
@ -0,0 +1,42 @@
|
||||||
|
%%--------------------------------------------------------------------
|
||||||
|
%% Copyright (c) 2024 EMQ Technologies Co., Ltd. All Rights Reserved.
|
||||||
|
%%--------------------------------------------------------------------
|
||||||
|
-module(emqx_bridge_clickhouse_connector_info).
|
||||||
|
|
||||||
|
-behaviour(emqx_connector_info).
|
||||||
|
|
||||||
|
-export([
|
||||||
|
type_name/0,
|
||||||
|
bridge_types/0,
|
||||||
|
resource_callback_module/0,
|
||||||
|
config_schema/0,
|
||||||
|
schema_module/0,
|
||||||
|
api_schema/1
|
||||||
|
]).
|
||||||
|
|
||||||
|
type_name() ->
|
||||||
|
clickhouse.
|
||||||
|
|
||||||
|
bridge_types() ->
|
||||||
|
[clickhouse].
|
||||||
|
|
||||||
|
resource_callback_module() ->
|
||||||
|
emqx_bridge_clickhouse_connector.
|
||||||
|
|
||||||
|
config_schema() ->
|
||||||
|
{clickhouse,
|
||||||
|
hoconsc:mk(
|
||||||
|
hoconsc:map(name, hoconsc:ref(emqx_bridge_clickhouse, "config_connector")),
|
||||||
|
#{
|
||||||
|
desc => <<"ClickHouse Connector Config">>,
|
||||||
|
required => false
|
||||||
|
}
|
||||||
|
)}.
|
||||||
|
|
||||||
|
schema_module() ->
|
||||||
|
emqx_bridge_clickhouse.
|
||||||
|
|
||||||
|
api_schema(Method) ->
|
||||||
|
emqx_connector_schema:api_ref(
|
||||||
|
emqx_bridge_clickhouse, <<"clickhouse">>, Method ++ "_connector"
|
||||||
|
).
|
|
@ -71,7 +71,8 @@ hard_coded_connector_info_modules_ee() ->
|
||||||
emqx_bridge_mongodb_connector_info,
|
emqx_bridge_mongodb_connector_info,
|
||||||
emqx_bridge_oracle_connector_info,
|
emqx_bridge_oracle_connector_info,
|
||||||
emqx_bridge_influxdb_connector_info,
|
emqx_bridge_influxdb_connector_info,
|
||||||
emqx_bridge_cassandra_connector_info
|
emqx_bridge_cassandra_connector_info,
|
||||||
|
emqx_bridge_clickhouse_connector_info
|
||||||
].
|
].
|
||||||
-else.
|
-else.
|
||||||
hard_coded_connector_info_modules_ee() ->
|
hard_coded_connector_info_modules_ee() ->
|
||||||
|
|
|
@ -21,8 +21,6 @@
|
||||||
|
|
||||||
resource_type(Type) when is_binary(Type) ->
|
resource_type(Type) when is_binary(Type) ->
|
||||||
resource_type(binary_to_atom(Type, utf8));
|
resource_type(binary_to_atom(Type, utf8));
|
||||||
resource_type(clickhouse) ->
|
|
||||||
emqx_bridge_clickhouse_connector;
|
|
||||||
resource_type(mysql) ->
|
resource_type(mysql) ->
|
||||||
emqx_bridge_mysql_connector;
|
emqx_bridge_mysql_connector;
|
||||||
resource_type(syskeeper_forwarder) ->
|
resource_type(syskeeper_forwarder) ->
|
||||||
|
@ -79,14 +77,6 @@ fields(connectors) ->
|
||||||
|
|
||||||
connector_structs() ->
|
connector_structs() ->
|
||||||
[
|
[
|
||||||
{clickhouse,
|
|
||||||
mk(
|
|
||||||
hoconsc:map(name, ref(emqx_bridge_clickhouse, "config_connector")),
|
|
||||||
#{
|
|
||||||
desc => <<"ClickHouse Connector Config">>,
|
|
||||||
required => false
|
|
||||||
}
|
|
||||||
)},
|
|
||||||
{mysql,
|
{mysql,
|
||||||
mk(
|
mk(
|
||||||
hoconsc:map(name, ref(emqx_bridge_mysql, "config_connector")),
|
hoconsc:map(name, ref(emqx_bridge_mysql, "config_connector")),
|
||||||
|
@ -203,7 +193,6 @@ connector_structs() ->
|
||||||
|
|
||||||
schema_modules() ->
|
schema_modules() ->
|
||||||
[
|
[
|
||||||
emqx_bridge_clickhouse,
|
|
||||||
emqx_bridge_mysql,
|
emqx_bridge_mysql,
|
||||||
emqx_bridge_syskeeper_connector,
|
emqx_bridge_syskeeper_connector,
|
||||||
emqx_bridge_syskeeper_proxy,
|
emqx_bridge_syskeeper_proxy,
|
||||||
|
@ -225,7 +214,6 @@ api_schemas(Method) ->
|
||||||
[
|
[
|
||||||
%% We need to map the `type' field of a request (binary) to a
|
%% We need to map the `type' field of a request (binary) to a
|
||||||
%% connector schema module.
|
%% connector schema module.
|
||||||
api_ref(emqx_bridge_clickhouse, <<"clickhouse">>, Method ++ "_connector"),
|
|
||||||
api_ref(emqx_bridge_mysql, <<"mysql">>, Method ++ "_connector"),
|
api_ref(emqx_bridge_mysql, <<"mysql">>, Method ++ "_connector"),
|
||||||
api_ref(emqx_bridge_syskeeper_connector, <<"syskeeper_forwarder">>, Method),
|
api_ref(emqx_bridge_syskeeper_connector, <<"syskeeper_forwarder">>, Method),
|
||||||
api_ref(emqx_bridge_syskeeper_proxy, <<"syskeeper_proxy">>, Method),
|
api_ref(emqx_bridge_syskeeper_proxy, <<"syskeeper_proxy">>, Method),
|
||||||
|
|
|
@ -127,8 +127,6 @@ connector_info_schema_modules() ->
|
||||||
|
|
||||||
%% @doc Return old bridge(v1) and/or connector(v2) type
|
%% @doc Return old bridge(v1) and/or connector(v2) type
|
||||||
%% from the latest connector type name.
|
%% from the latest connector type name.
|
||||||
connector_type_to_bridge_types(clickhouse) ->
|
|
||||||
[clickhouse];
|
|
||||||
connector_type_to_bridge_types(mysql) ->
|
connector_type_to_bridge_types(mysql) ->
|
||||||
[mysql];
|
[mysql];
|
||||||
connector_type_to_bridge_types(mqtt) ->
|
connector_type_to_bridge_types(mqtt) ->
|
||||||
|
|
Loading…
Reference in New Issue