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

feat(resource): increase default request timeout to 45 s 

See
https://emqx.atlassian.net/wiki/spaces/P/pages/612368639/open+e5.1+remove+auto+restart+interval+from+buffer+worker+resource+options
This commit is contained in:
Thales Macedo Garitezi 2023-06-01 09:40:11 -03:00
parent 10425eb925
commit f42ccb6262
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -86,7 +86,8 @@
-define(DEFAULT_BUFFER_BYTES, 256 * 1024 * 1024). -define(DEFAULT_BUFFER_BYTES, 256 * 1024 * 1024).
-define(DEFAULT_BUFFER_BYTES_RAW, <<"256MB">>). -define(DEFAULT_BUFFER_BYTES_RAW, <<"256MB">>).
-define(DEFAULT_REQUEST_TIMEOUT, timer:seconds(15)). -define(DEFAULT_REQUEST_TIMEOUT, timer:seconds(45)).
-define(DEFAULT_REQUEST_TIMEOUT_RAW, <<"45s">>).
%% count %% count
-define(DEFAULT_BATCH_SIZE, 1). -define(DEFAULT_BATCH_SIZE, 1).

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

@ -135,7 +135,7 @@ query_mode(_) -> undefined.
request_timeout(type) -> hoconsc:union([infinity, emqx_schema:duration_ms()]); request_timeout(type) -> hoconsc:union([infinity, emqx_schema:duration_ms()]);
request_timeout(desc) -> ?DESC("request_timeout"); request_timeout(desc) -> ?DESC("request_timeout");
request_timeout(default) -> <<"15s">>; request_timeout(default) -> ?DEFAULT_REQUEST_TIMEOUT_RAW;
request_timeout(_) -> undefined. request_timeout(_) -> undefined.
enable_batch(type) -> boolean(); enable_batch(type) -> boolean();