feat: adds the greptimedb bridge to emqx modules

This commit is contained in:
Dennis Zhuang 2023-05-09 16:10:14 +08:00 committed by firest
parent 4d581d0b30
commit c5078980f3
5 changed files with 19 additions and 3 deletions

View File

@ -89,7 +89,8 @@
T == pulsar_producer; T == pulsar_producer;
T == oracle; T == oracle;
T == iotdb; T == iotdb;
T == kinesis_producer T == kinesis_producer;
T == greptimedb
). ).
-define(ROOT_KEY, bridges). -define(ROOT_KEY, bridges).

View File

@ -49,7 +49,8 @@ api_schemas(Method) ->
api_ref(emqx_bridge_oracle, <<"oracle">>, Method), api_ref(emqx_bridge_oracle, <<"oracle">>, Method),
api_ref(emqx_bridge_iotdb, <<"iotdb">>, Method), api_ref(emqx_bridge_iotdb, <<"iotdb">>, Method),
api_ref(emqx_bridge_rabbitmq, <<"rabbitmq">>, Method), api_ref(emqx_bridge_rabbitmq, <<"rabbitmq">>, Method),
api_ref(emqx_bridge_kinesis, <<"kinesis_producer">>, Method ++ "_producer") api_ref(emqx_bridge_kinesis, <<"kinesis_producer">>, Method ++ "_producer"),
api_ref(emqx_bridge_greptimedb, Method)
]. ].
schema_modules() -> schema_modules() ->
@ -75,7 +76,8 @@ schema_modules() ->
emqx_bridge_oracle, emqx_bridge_oracle,
emqx_bridge_iotdb, emqx_bridge_iotdb,
emqx_bridge_rabbitmq, emqx_bridge_rabbitmq,
emqx_bridge_kinesis emqx_bridge_kinesis,
emqx_bridge_greptimedb
]. ].
examples(Method) -> examples(Method) ->
@ -122,6 +124,8 @@ resource_type(oracle) -> emqx_oracle;
resource_type(iotdb) -> emqx_bridge_iotdb_impl; resource_type(iotdb) -> emqx_bridge_iotdb_impl;
resource_type(rabbitmq) -> emqx_bridge_rabbitmq_connector; resource_type(rabbitmq) -> emqx_bridge_rabbitmq_connector;
resource_type(kinesis_producer) -> emqx_bridge_kinesis_impl_producer. resource_type(kinesis_producer) -> emqx_bridge_kinesis_impl_producer.
resource_type(rabbitmq) -> emqx_bridge_rabbitmq_connector.
resource_type(greptimedb) -> emqx_bridge_greptimedb_connector.
fields(bridges) -> fields(bridges) ->
[ [
@ -197,6 +201,14 @@ fields(bridges) ->
desc => <<"Apache IoTDB Bridge Config">>, desc => <<"Apache IoTDB Bridge Config">>,
required => false required => false
} }
)},
{greptimedb,
mk(
hoconsc:map(name, ref(emqx_bridge_greptimedb, "config")),
#{
desc => <<"GreptimeDB Bridge Config">>,
required => false
}
)} )}
] ++ kafka_structs() ++ pulsar_structs() ++ gcp_pubsub_structs() ++ mongodb_structs() ++ ] ++ kafka_structs() ++ pulsar_structs() ++ gcp_pubsub_structs() ++ mongodb_structs() ++
influxdb_structs() ++ influxdb_structs() ++

View File

@ -0,0 +1 @@
-module(emqx_bridge_greptimedb_connector).

View File

@ -171,6 +171,7 @@ defmodule EMQXUmbrella.MixProject do
:emqx_bridge_cassandra, :emqx_bridge_cassandra,
:emqx_bridge_opents, :emqx_bridge_opents,
:emqx_bridge_dynamo, :emqx_bridge_dynamo,
:emqx_bridge_greptimedb,
:emqx_bridge_hstreamdb, :emqx_bridge_hstreamdb,
:emqx_bridge_influxdb, :emqx_bridge_influxdb,
:emqx_bridge_iotdb, :emqx_bridge_iotdb,

View File

@ -29,6 +29,7 @@ EPMD
ERL ERL
ETS ETS
FIXME FIXME
GreptimeDB
GCM GCM
HMAC HMAC
HOCON HOCON