yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: refine influxdb connector api type name

This commit is contained in:
JimMoen 2022-08-04 13:40:00 +08:00
parent 2e336fbc01
commit 33a604dcaa
2 changed files with 24 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib-ee/emqx_ee_connector/src/emqx_ee_connector.erl
View File

@ -14,9 +14,9 @@
api_schemas(Method) -> api_schemas(Method) ->
[ [
ref(emqx_ee_connector_hstreamdb, Method), ref(emqx_ee_connector_hstreamdb, Method),
ref(emqx_ee_connector_influxdb, Method ++ "_udp"), ref(emqx_ee_connector_influxdb, "udp_" ++ Method),
ref(emqx_ee_connector_influxdb, Method ++ "_api_v1"), ref(emqx_ee_connector_influxdb, "api_v1_" ++ Method),
ref(emqx_ee_connector_influxdb, Method ++ "_api_v2") ref(emqx_ee_connector_influxdb, "api_v2_" ++ Method)
]. ].
fields(connectors) -> fields(connectors) ->

42
lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
View File

@ -49,30 +49,30 @@ on_get_status(_InstId, #{client := Client}) ->
%% schema %% schema
namespace() -> connector_influxdb. namespace() -> connector_influxdb.
fields("put_udp") -> fields("udp_get") ->
Key = influxdb_udp,
fields(Key) ++ type_name_field(Key);
fields("udp_post") ->
Key = influxdb_udp,
fields(Key) ++ type_name_field(Key);
fields("udp_put") ->
fields(influxdb_udp); fields(influxdb_udp);
fields("put_api_v1") -> fields("api_v1_get") ->
Key = influxdb_api_v1,
fields(Key) ++ type_name_field(Key);
fields("api_v1_post") ->
Key = influxdb_api_v1,
fields(Key) ++ type_name_field(Key);
fields("api_v1_put") ->
fields(influxdb_api_v1); fields(influxdb_api_v1);
fields("put_api_v2") -> fields("api_v2_get") ->
Key = influxdb_api_v2,
fields(Key) ++ type_name_field(Key);
fields("api_v2_post") ->
Key = influxdb_api_v2,
fields(Key) ++ type_name_field(Key);
fields("api_v2_put") ->
fields(influxdb_api_v2); fields(influxdb_api_v2);
fields("get_udp") ->
Key = influxdb_udp,
fields(Key) ++ type_name_field(Key);
fields("get_api_v1") ->
Key = influxdb_api_v1,
fields(Key) ++ type_name_field(Key);
fields("get_api_v2") ->
Key = influxdb_api_v2,
fields(Key) ++ type_name_field(Key);
fields("post_udp") ->
Key = influxdb_udp,
fields(Key) ++ type_name_field(Key);
fields("post_api_v1") ->
Key = influxdb_api_v1,
fields(Key) ++ type_name_field(Key);
fields("post_api_v2") ->
Key = influxdb_api_v2,
fields(Key) ++ type_name_field(Key);
fields(basic) -> fields(basic) ->
[ [
{host, {host,