Browse Source

fix(gcp_pubsub_producer): add missing references to api specs

Thales Macedo Garitezi 2 years ago
parent
commit
f3693e5dbc

+ 11 - 2
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");

+ 6 - 0
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)
     ].