From a0cd877669939c88bd8bff3b80c43fe297bad7c4 Mon Sep 17 00:00:00 2001 From: Ilya Averyanov Date: Wed, 2 Mar 2022 16:26:39 +0300 Subject: [PATCH] chore(mongodb): do not use mongodb internal pool --- apps/emqx_connector/src/emqx_connector_mongo.erl | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/apps/emqx_connector/src/emqx_connector_mongo.erl b/apps/emqx_connector/src/emqx_connector_mongo.erl index 135ba3382..bf710383b 100644 --- a/apps/emqx_connector/src/emqx_connector_mongo.erl +++ b/apps/emqx_connector/src/emqx_connector_mongo.erl @@ -73,7 +73,7 @@ fields(sharded) -> , {w_mode, fun w_mode/1} ] ++ mongo_fields(); fields(topology) -> - [ {pool_size, fun emqx_connector_schema_lib:pool_size/1} + [ {pool_size, fun internal_pool_size/1} , {max_overflow, fun emqx_connector_schema_lib:pool_size/1} , {overflow_ttl, fun duration/1} , {overflow_check_period, fun duration/1} @@ -97,6 +97,11 @@ mongo_fields() -> ] ++ emqx_connector_schema_lib:ssl_fields(). +internal_pool_size(type) -> integer(); +internal_pool_size(default) -> 1; +internal_pool_size(validator) -> [?MIN(1)]; +internal_pool_size(_) -> undefined. + %% =================================================================== on_start(InstId, Config = #{mongo_type := Type,