chore: use HStreamDB for module name

This commit is contained in:
JimMoen 2022-08-04 10:10:38 +08:00
parent 6f8ceacece
commit 4d0516c6e9
8 changed files with 14 additions and 14 deletions

View File

@ -1,4 +1,4 @@
emqx_ee_bridge_hstream { emqx_ee_bridge_hstreamdb {
local_topic { local_topic {
desc { desc {
en: """ en: """

View File

@ -14,8 +14,8 @@
api_schemas(Method) -> api_schemas(Method) ->
[ [
ref(emqx_ee_bridge_hstream, Method),
ref(emqx_ee_bridge_mysql, Method), ref(emqx_ee_bridge_mysql, Method),
ref(emqx_ee_bridge_hstreamdb, Method),
ref(emqx_ee_bridge_influxdb, Method ++ "_udp"), ref(emqx_ee_bridge_influxdb, Method ++ "_udp"),
ref(emqx_ee_bridge_influxdb, Method ++ "_api_v1"), ref(emqx_ee_bridge_influxdb, Method ++ "_api_v1"),
ref(emqx_ee_bridge_influxdb, Method ++ "_api_v2") ref(emqx_ee_bridge_influxdb, Method ++ "_api_v2")
@ -23,7 +23,7 @@ api_schemas(Method) ->
schema_modules() -> schema_modules() ->
[ [
emqx_ee_bridge_hstream, emqx_ee_bridge_hstreamdb,
emqx_ee_bridge_influxdb, emqx_ee_bridge_influxdb,
emqx_ee_bridge_mysql emqx_ee_bridge_mysql
]. ].
@ -41,7 +41,7 @@ conn_bridge_examples(Method) ->
lists:foldl(Fun, #{}, schema_modules()). lists:foldl(Fun, #{}, schema_modules()).
resource_type(Type) when is_binary(Type) -> resource_type(binary_to_atom(Type, utf8)); resource_type(Type) when is_binary(Type) -> resource_type(binary_to_atom(Type, utf8));
resource_type(hstreamdb) -> emqx_ee_connector_hstream; resource_type(hstreamdb) -> emqx_ee_connector_hstreamdb;
resource_type(mysql) -> emqx_connector_mysql; resource_type(mysql) -> emqx_connector_mysql;
resource_type(influxdb_udp) -> emqx_ee_connector_influxdb; resource_type(influxdb_udp) -> emqx_ee_connector_influxdb;
resource_type(influxdb_api_v1) -> emqx_ee_connector_influxdb; resource_type(influxdb_api_v1) -> emqx_ee_connector_influxdb;
@ -51,7 +51,7 @@ fields(bridges) ->
[ [
{hstreamdb, {hstreamdb,
mk( mk(
hoconsc:map(name, ref(emqx_ee_bridge_hstream, "config")), hoconsc:map(name, ref(emqx_ee_bridge_hstreamdb, "config")),
#{desc => <<"EMQX Enterprise Config">>} #{desc => <<"EMQX Enterprise Config">>}
)}, )},
{mysql, {mysql,

View File

@ -1,7 +1,7 @@
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Copyright (c) 2022 EMQ Technologies Co., Ltd. All Rights Reserved. %% Copyright (c) 2022 EMQ Technologies Co., Ltd. All Rights Reserved.
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
-module(emqx_ee_bridge_hstream). -module(emqx_ee_bridge_hstreamdb).
-include_lib("typerefl/include/types.hrl"). -include_lib("typerefl/include/types.hrl").
-include_lib("hocon/include/hoconsc.hrl"). -include_lib("hocon/include/hoconsc.hrl").
@ -71,7 +71,7 @@ fields("get") ->
field(connector) -> field(connector) ->
mk( mk(
hoconsc:union([binary(), ref(emqx_ee_connector_hstream, config)]), hoconsc:union([binary(), ref(emqx_ee_connector_hstreamdb, config)]),
#{ #{
required => true, required => true,
example => <<"hstreamdb:demo">>, example => <<"hstreamdb:demo">>,

View File

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

View File

@ -1,5 +1,5 @@
emqx_ee_connector_hstream { emqx_ee_connector_hstreamdb {
type { type {
desc { desc {
en: "The Connector Type." en: "The Connector Type."

View File

@ -13,7 +13,7 @@
api_schemas(Method) -> api_schemas(Method) ->
[ [
ref(emqx_ee_connector_hstream, Method), ref(emqx_ee_connector_hstreamdb, Method),
ref(emqx_ee_connector_influxdb, Method ++ "_udp"), ref(emqx_ee_connector_influxdb, Method ++ "_udp"),
ref(emqx_ee_connector_influxdb, Method ++ "_api_v1"), ref(emqx_ee_connector_influxdb, Method ++ "_api_v1"),
ref(emqx_ee_connector_influxdb, Method ++ "_api_v2") ref(emqx_ee_connector_influxdb, Method ++ "_api_v2")
@ -23,7 +23,7 @@ fields(connectors) ->
[ [
{hstreamdb, {hstreamdb,
mk( mk(
hoconsc:map(name, ref(emqx_ee_connector_hstream, config)), hoconsc:map(name, ref(emqx_ee_connector_hstreamdb, config)),
#{desc => <<"EMQX Enterprise Config">>} #{desc => <<"EMQX Enterprise Config">>}
)} )}
] ++ fields(influxdb); ] ++ fields(influxdb);
@ -52,6 +52,6 @@ connector_examples(Method) ->
schema_modules() -> schema_modules() ->
[ [
emqx_ee_connector_hstream, emqx_ee_connector_hstreamdb,
emqx_ee_connector_influxdb emqx_ee_connector_influxdb
]. ].

View File

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

View File

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