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

fix(mysql_bridge): export the query_mode option to the APIs

This commit is contained in:
Shawn 2022-08-25 11:38:50 +08:00
parent ddb5bd23d6
commit 9327c0f51b
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_rule_engine/src/emqx_rule_runtime.erl
View File

@ -509,10 +509,10 @@ inc_action_metrics(ok, RuleId) ->
inc_action_metrics({ok, _}, RuleId) -> inc_action_metrics({ok, _}, RuleId) ->
emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.success'); emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.success');
inc_action_metrics({resource_down, _}, RuleId) -> inc_action_metrics({resource_down, _}, RuleId) ->
emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.out_of_service'), emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed.out_of_service'),
emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed.unknown'); emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed.unknown');
inc_action_metrics(?RESOURCE_ERROR_M(R, _), RuleId) when ?IS_RES_DOWN(R) -> inc_action_metrics(?RESOURCE_ERROR_M(R, _), RuleId) when ?IS_RES_DOWN(R) ->
emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.out_of_service'), emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed.out_of_service'),
emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed.unknown'); emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed.unknown');
inc_action_metrics(_, RuleId) -> inc_action_metrics(_, RuleId) ->
emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed'), emqx_metrics_worker:inc(rule_metrics, RuleId, 'actions.failed'),

3
lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_mysql.erl
View File

@ -60,6 +60,7 @@ values(post) ->
enable_batch => false, enable_batch => false,
batch_size => ?DEFAULT_BATCH_SIZE, batch_size => ?DEFAULT_BATCH_SIZE,
batch_time => ?DEFAULT_BATCH_TIME, batch_time => ?DEFAULT_BATCH_TIME,
query_mode => sync,
enable_queue => false, enable_queue => false,
max_queue_bytes => ?DEFAULT_QUEUE_SIZE max_queue_bytes => ?DEFAULT_QUEUE_SIZE
} }
@ -120,7 +121,7 @@ desc(_) ->
%% internal %% internal
is_hidden_opts(Field) -> is_hidden_opts(Field) ->
lists:member(Field, [ lists:member(Field, [
query_mode, async_inflight_window async_inflight_window
]). ]).
type_field() -> type_field() ->