diff --git a/apps/emqx_conf/src/emqx_conf_schema.erl b/apps/emqx_conf/src/emqx_conf_schema.erl index d8bb2423b..91ef5d812 100644 --- a/apps/emqx_conf/src/emqx_conf_schema.erl +++ b/apps/emqx_conf/src/emqx_conf_schema.erl @@ -347,6 +347,23 @@ to rlog. List of core nodes that the replicant will connect to.
Note: this parameter only takes effect when the backend is set to rlog and the role is set to replicant. +""" + })} + , {"rpc_module", + sc(hoconsc:enum([gen_rpc, rpc]), + #{ mapping => "mria.rlog_rpc_module" + , default => gen_rpc + , desc => """ +Protocol used for pushing transaction logs to the replicant nodes. +""" + })} + , {"tlog_push_mode", + sc(hoconsc:enum([sync, async]), + #{ mapping => "mria.tlog_push_mode" + , default => async + , desc => """ +In sync mode the core node waits for an ack from the replicant nodes before sending the next +transaction log entry. """ })} ]; diff --git a/rebar.config b/rebar.config index 9e7aba87c..4fbf1b136 100644 --- a/rebar.config +++ b/rebar.config @@ -52,7 +52,7 @@ , {jiffy, {git, "https://github.com/emqx/jiffy", {tag, "1.0.5"}}} , {cowboy, {git, "https://github.com/emqx/cowboy", {tag, "2.8.3"}}} , {esockd, {git, "https://github.com/emqx/esockd", {tag, "5.9.0"}}} - , {mria, {git, "https://github.com/emqx/mria", {tag, "0.1.3"}}} + , {mria, {git, "https://github.com/emqx/mria", {tag, "0.1.4"}}} , {ekka, {git, "https://github.com/emqx/ekka", {tag, "0.11.1"}}} , {gen_rpc, {git, "https://github.com/emqx/gen_rpc", {tag, "2.5.1"}}} , {minirest, {git, "https://github.com/emqx/minirest", {tag, "1.2.7"}}}