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

fix: syntax error and compile error

This commit is contained in:
JimMoen 2022-08-11 19:45:52 +08:00
parent ed749df5c6
commit 3a76a50382
4 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge/src/emqx_bridge_resource.erl
View File

@ -34,7 +34,7 @@
create_dry_run/2, create_dry_run/2,
remove/1, remove/1,
remove/2, remove/2,
remove/3, remove/4,
update/2, update/2,
update/3, update/3,
stop/2, stop/2,

2
apps/emqx_resource/include/emqx_resource.hrl
View File

@ -58,7 +58,7 @@
batch_time => integer(), batch_time => integer(),
enable_queue => boolean(), enable_queue => boolean(),
queue_max_bytes => integer(), queue_max_bytes => integer(),
query_mode => async | sync | dynamic query_mode => async | sync | dynamic,
resume_interval => integer(), resume_interval => integer(),
async_inflight_window => integer() async_inflight_window => integer()
}. }.

2
apps/emqx_resource/src/emqx_resource.erl
View File

@ -295,7 +295,7 @@ fetch_creation_opts(Opts) ->
resume_interval, resume_interval,
async_inflight_window async_inflight_window
], ],
maps:with(creation_opts(), SupportedOpts). maps:with(SupportedOpts, Opts).
-spec list_instances() -> [resource_id()]. -spec list_instances() -> [resource_id()].
list_instances() -> list_instances() ->

4
lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl
View File

@ -71,7 +71,9 @@ values(Protocol, post) ->
<<"${topic},clientid=${clientid}", " ", "payload=${payload},", <<"${topic},clientid=${clientid}", " ", "payload=${payload},",
"${clientid}_int_value=${payload.int_key}i,", SupportUint/binary, "${clientid}_int_value=${payload.int_key}i,", SupportUint/binary,
"bool=${payload.bool}">>, "bool=${payload.bool}">>,
batch => #{enable_batch => false, batch_size => 5, batch_time => <<"1m">>} enable_batch => false,
batch_size => 5,
batch_time => <<"1m">>
}; };
values(Protocol, put) -> values(Protocol, put) ->
values(Protocol, post). values(Protocol, post).