111 lines
2.8 KiB
Erlang
111 lines
2.8 KiB
Erlang
%%-*- mode: erlang -*-
|
|
%% EMQ X R3.0 config mapping
|
|
|
|
{mapping, "web.hook.url", "emqx_web_hook.url", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.headers.$name", "emqx_web_hook.headers", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.body.encoding_of_payload_field", "emqx_web_hook.encoding_of_payload_field", [
|
|
{default, plain},
|
|
{datatype, {enum, [plain, base62, base64]}}
|
|
]}.
|
|
|
|
{mapping, "web.hook.ssl.cacertfile", "emqx_web_hook.cacertfile", [
|
|
{default, ""},
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.ssl.certfile", "emqx_web_hook.certfile", [
|
|
{default, ""},
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.ssl.keyfile", "emqx_web_hook.keyfile", [
|
|
{default, ""},
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.ssl.verify", "emqx_web_hook.verify", [
|
|
{default, false},
|
|
{datatype, {enum, [true, false]}}
|
|
]}.
|
|
|
|
{mapping, "web.hook.ssl.server_name_indication", "emqx_web_hook.server_name_indication", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.pool_size", "emqx_web_hook.pool_size", [
|
|
{default, 32},
|
|
{datatype, integer}
|
|
]}.
|
|
|
|
{mapping, "web.hook.enable_pipelining", "emqx_web_hook.enable_pipelining", [
|
|
{default, true},
|
|
{datatype, {enum, [true, false]}}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.client.connect.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.client.connack.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.client.connected.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.client.disconnected.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.client.subscribe.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.client.unsubscribe.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.session.subscribed.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.session.unsubscribed.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.session.terminated.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.message.publish.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.message.acked.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{mapping, "web.hook.rule.message.delivered.$name", "emqx_web_hook.rules", [
|
|
{datatype, string}
|
|
]}.
|
|
|
|
{translation, "emqx_web_hook.headers", fun(Conf) ->
|
|
Headers = cuttlefish_variable:filter_by_prefix("web.hook.headers", Conf),
|
|
[{K, V} || {[_, _, _, K], V} <- Headers]
|
|
end}.
|
|
|
|
{translation, "emqx_web_hook.rules", fun(Conf) ->
|
|
Hooks = cuttlefish_variable:filter_by_prefix("web.hook.rule", Conf),
|
|
lists:map(
|
|
fun({[_, _, _,Name1,Name2, _], Val}) ->
|
|
{lists:concat([Name1,".",Name2]), Val}
|
|
end, Hooks)
|
|
end}.
|