fix: bridge and connector namespace contains DB name

Contains Detailed DB name for identifier hocon schema refs.
This commit is contained in:
JimMoen 2022-08-04 10:17:09 +08:00
parent 4d0516c6e9
commit 2e336fbc01
5 changed files with 7 additions and 3 deletions

View File

@ -9,7 +9,7 @@
%%====================================================================================== %%======================================================================================
%% Hocon Schema Definitions %% Hocon Schema Definitions
namespace() -> "bridge". namespace() -> "bridge_webhook".
roots() -> []. roots() -> [].

View File

@ -50,7 +50,7 @@ values(put) ->
%% ------------------------------------------------------------------------------------------------- %% -------------------------------------------------------------------------------------------------
%% Hocon Schema Definitions %% Hocon Schema Definitions
namespace() -> "bridge". namespace() -> "bridge_hstreamdb".
roots() -> []. roots() -> [].

View File

@ -68,7 +68,7 @@ values(Protocol, put) ->
%% ------------------------------------------------------------------------------------------------- %% -------------------------------------------------------------------------------------------------
%% Hocon Schema Definitions %% Hocon Schema Definitions
namespace() -> "bridge". namespace() -> "bridge_influxdb".
roots() -> []. roots() -> [].

View File

@ -24,6 +24,7 @@
]). ]).
-export([ -export([
namespace/0,
roots/0, roots/0,
fields/1, fields/1,
connector_examples/1 connector_examples/1
@ -75,6 +76,7 @@ on_flush_result({{flush, _Stream, _Records}, {error, _Reason}}) ->
%% ------------------------------------------------------------------------------------------------- %% -------------------------------------------------------------------------------------------------
%% schema %% schema
namespace() -> connector_hstreamdb.
roots() -> roots() ->
fields(config). fields(config).

View File

@ -20,6 +20,7 @@
]). ]).
-export([ -export([
namespace/0,
fields/1, fields/1,
connector_examples/1 connector_examples/1
]). ]).
@ -46,6 +47,7 @@ on_get_status(_InstId, #{client := Client}) ->
%% ------------------------------------------------------------------------------------------------- %% -------------------------------------------------------------------------------------------------
%% schema %% schema
namespace() -> connector_influxdb.
fields("put_udp") -> fields("put_udp") ->
fields(influxdb_udp); fields(influxdb_udp);