diff --git a/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_producer_schema.erl b/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_producer_schema.erl index 11ca16e0b..0ee625824 100644 --- a/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_producer_schema.erl +++ b/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_producer_schema.erl @@ -71,14 +71,23 @@ fields("config_connector") -> emqx_bridge_gcp_pubsub:fields(connector_config) ++ emqx_resource_schema:fields("resource_opts"); %%========================================= -%% HTTP API fields +%% HTTP API fields: action %%========================================= fields("get_bridge_v2") -> emqx_bridge_schema:status_fields() ++ fields("post_bridge_v2"); fields("post_bridge_v2") -> [type_field(), name_field() | fields("put_bridge_v2")]; fields("put_bridge_v2") -> - fields(producer_action). + fields(producer_action); +%%========================================= +%% HTTP API fields: connector +%%========================================= +fields("get_connector") -> + emqx_bridge_schema:status_fields() ++ fields("post_connector"); +fields("post_connector") -> + [type_field(), name_field() | fields("put_connector")]; +fields("put_connector") -> + fields("config_connector"). desc("config_connector") -> ?DESC("config_connector"); diff --git a/apps/emqx_connector/src/schema/emqx_connector_ee_schema.erl b/apps/emqx_connector/src/schema/emqx_connector_ee_schema.erl index 27b068461..6c303dd7e 100644 --- a/apps/emqx_connector/src/schema/emqx_connector_ee_schema.erl +++ b/apps/emqx_connector/src/schema/emqx_connector_ee_schema.erl @@ -117,6 +117,7 @@ schema_modules() -> [ emqx_bridge_azure_event_hub, emqx_bridge_confluent_producer, + emqx_bridge_gcp_pubsub_producer_schema, emqx_bridge_kafka, emqx_bridge_syskeeper_connector, emqx_bridge_syskeeper_proxy @@ -133,6 +134,11 @@ api_schemas(Method) -> emqx_bridge_confluent_producer, <<"confluent_producer">>, Method ++ "_connector" ), api_ref(emqx_bridge_kafka, <<"kafka_producer">>, Method ++ "_connector"), + api_ref( + emqx_bridge_gcp_pubsub_producer_schema, + <<"gcp_pubsub_producer">>, + Method ++ "_connector" + ), api_ref(emqx_bridge_syskeeper_connector, <<"syskeeper_forwarder">>, Method), api_ref(emqx_bridge_syskeeper_proxy, <<"syskeeper_proxy">>, Method) ].