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

refactor: rename rpc.tcp_client_num to rpc.client_num 

tcp_client_num is kept as an alias
This commit is contained in:
zmstone 2024-07-04 21:34:35 +02:00
parent 6d94809950
commit ee13773496
3 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_rpc.erl
View File

@ -137,7 +137,7 @@ maybe_badrpc(Delivery) ->
Delivery. Delivery.
max_client_num() -> max_client_num() ->
emqx:get_config([rpc, tcp_client_num], ?DefaultClientNum). emqx:get_config([rpc, client_num], ?DefaultClientNum).
-spec unwrap_erpc(emqx_rpc:erpc(A) | [emqx_rpc:erpc(A)]) -> A | {error, _Err} | list(). -spec unwrap_erpc(emqx_rpc:erpc(A) | [emqx_rpc:erpc(A)]) -> A | {error, _Err} | list().
unwrap_erpc(Res) when is_list(Res) -> unwrap_erpc(Res) when is_list(Res) ->

5
apps/emqx_conf/src/emqx_conf_schema.erl
View File

@ -774,12 +774,13 @@ fields("rpc") ->
desc => ?DESC(rpc_ssl_server_port) desc => ?DESC(rpc_ssl_server_port)
} }
)}, )},
{"tcp_client_num", {"client_num",
sc( sc(
range(1, 256), range(1, 256),
#{ #{
aliases => [tcp_client_num]
default => 10, default => 10,
desc => ?DESC(rpc_tcp_client_num) desc => ?DESC(rpc_client_num)
} }
)}, )},
{"connect_timeout", {"connect_timeout",

4
rel/i18n/emqx_conf_schema.hocon
View File

@ -383,10 +383,10 @@ log_burst_limit_max_count.desc:
log_burst_limit_max_count.label: log_burst_limit_max_count.label:
"""Events Number""" """Events Number"""
rpc_tcp_client_num.desc: rpc_client_num.desc:
"""Set the maximum number of RPC communication channels initiated by this node to each remote node.""" """Set the maximum number of RPC communication channels initiated by this node to each remote node."""
rpc_tcp_client_num.label: rpc_client_num.label:
"""RPC TCP Client Num""" """RPC TCP Client Num"""
cluster_k8s_address_type.desc: cluster_k8s_address_type.desc: