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

Merge pull request #6912 from k32/gen-rpc-client-driver 

fix(emqx_schema): Set gen_rpc_client_driver automatically
This commit is contained in:
k32 2022-02-02 14:52:24 +01:00 committed by GitHub
parent dfdadbd124 a54b4ddfd0
commit ff1589c837
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -459,13 +459,15 @@ fields("rpc") ->
, {"keyfile",
sc(file(),
#{ mapping => "gen_rpc.keyfile"
, desc => "Path to the private key file for the <code>rpc.certfile</code>."
, desc => "Path to the private key file for the <code>rpc.certfile</code>.<br/>"
"Note: contents of this file are secret, so it's necessary to set permissions to 600."
})}
, {"cacertfile",
sc(file(),
#{ mapping => "gen_rpc.cacertfile"
, desc => "Path to certification authority TLS certificate file used to validate "
"<code>rpc.certfile</code>."
"<code>rpc.certfile</code>.<br/>"
"Note: certificates of all nodes in the cluster must be signed by the same CA."
})}
, {"send_timeout",
sc(emqx_schema:duration(),
@ -603,7 +605,7 @@ fields("authorization") ->
emqx_schema:fields("authorization") ++
emqx_authz_schema:fields("authorization").
translations() -> ["ekka", "kernel", "emqx"].
translations() -> ["ekka", "kernel", "emqx", "gen_rpc"].
translation("ekka") ->
[ {"cluster_discovery", fun tr_cluster_discovery/1}];
@ -614,8 +616,14 @@ translation("emqx") ->
[ {"config_files", fun tr_config_files/1}
, {"cluster_override_conf_file", fun tr_cluster_override_conf_file/1}
, {"local_override_conf_file", fun tr_local_override_conf_file/1}
];
translation("gen_rpc") ->
[ {"default_client_driver", fun tr_default_config_driver/1}
].
tr_default_config_driver(Conf) ->
conf_get("rpc.driver", Conf).
tr_config_files(Conf) ->
case conf_get("emqx.config_files", Conf) of
[_ | _] = Files ->