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

Merge pull request #11841 from sstrigler/EMQX-11269-bridges-in-swagger-several-errors 

EMQX-11269 bridges in swagger several errors
This commit is contained in:
Stefan Strigler 2023-10-30 16:44:53 +01:00 committed by GitHub
parent 19554850a9 5a6e55e7af
commit b58dd773ef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
apps/emqx_bridge_kafka/src/emqx_bridge_kafka.erl
View File

@ -39,10 +39,11 @@
connector_examples(_Method) -> connector_examples(_Method) ->
[ [
#{ #{
<<"kafka">> => #{ <<"kafka_producer">> => #{
summary => <<"Kafka Connector">>, summary => <<"Kafka Connector">>,
value => maps:merge( value => maps:merge(
#{name => <<"my_connector">>, type => <<"kafka">>}, values(common_config) #{name => <<"my_connector">>, type => <<"kafka_producer">>},
values(common_config)
) )
} }
} }
@ -61,7 +62,7 @@ bridge_v2_examples(Method) ->
conn_bridge_examples(Method) -> conn_bridge_examples(Method) ->
[ [
#{ #{
<<"kafka">> => #{ <<"kafka_producer">> => #{
summary => <<"Kafka Producer Bridge">>, summary => <<"Kafka Producer Bridge">>,
value => values({Method, producer}) value => values({Method, producer})
} }
@ -90,8 +91,8 @@ values({get, KafkaType}) ->
values({post, KafkaType}) -> values({post, KafkaType}) ->
maps:merge( maps:merge(
#{ #{
name => <<"my_bridge">>, name => <<"my_kafka_bridge">>,
type => <<"kafka">> type => <<"kafka_producer">>
}, },
values({put, KafkaType}) values({put, KafkaType})
); );
@ -612,7 +613,7 @@ struct_names() ->
%% ------------------------------------------------------------------------------------------------- %% -------------------------------------------------------------------------------------------------
%% internal %% internal
type_field("connector") -> type_field(BridgeV2Type) when BridgeV2Type =:= "connector"; BridgeV2Type =:= "bridge_v2" ->
{type, mk(enum([kafka_producer]), #{required => true, desc => ?DESC("desc_type")})}; {type, mk(enum([kafka_producer]), #{required => true, desc => ?DESC("desc_type")})};
type_field(_) -> type_field(_) ->
{type, {type,