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

Merge pull request #7963 from HJianBo/add-proto-name-for-client-disconnected-v5 

feat(rule-engine): add proto_name/proto_ver for $event/client_disconnected event
This commit is contained in:
JianBo He 2022-05-16 18:06:06 +08:00 committed by GitHub
parent addb48af7d d8ec51a0c2
commit 4d35338cd1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqx_rule_engine/src/emqx_rule_events.erl
View File

@ -307,6 +307,8 @@ eventmsg_disconnected(
ConnInfo = #{ ConnInfo = #{
peername := PeerName, peername := PeerName,
sockname := SockName, sockname := SockName,
proto_name := ProtoName,
proto_ver := ProtoVer,
disconnected_at := DisconnectedAt disconnected_at := DisconnectedAt
}, },
Reason Reason
@ -319,6 +321,8 @@ eventmsg_disconnected(
username => Username, username => Username,
peername => ntoa(PeerName), peername => ntoa(PeerName),
sockname => ntoa(SockName), sockname => ntoa(SockName),
proto_name => ProtoName,
proto_ver => ProtoVer,
disconn_props => printable_maps(maps:get(disconn_props, ConnInfo, #{})), disconn_props => printable_maps(maps:get(disconn_props, ConnInfo, #{})),
disconnected_at => DisconnectedAt disconnected_at => DisconnectedAt
} }
@ -844,6 +848,8 @@ columns_with_exam('client.disconnected') ->
{<<"username">>, <<"u_emqx">>}, {<<"username">>, <<"u_emqx">>},
{<<"peername">>, <<"192.168.0.10:56431">>}, {<<"peername">>, <<"192.168.0.10:56431">>},
{<<"sockname">>, <<"0.0.0.0:1883">>}, {<<"sockname">>, <<"0.0.0.0:1883">>},
{<<"proto_name">>, <<"MQTT">>},
{<<"proto_ver">>, 5},
columns_example_props(disconn_props), columns_example_props(disconn_props),
{<<"disconnected_at">>, erlang:system_time(millisecond)}, {<<"disconnected_at">>, erlang:system_time(millisecond)},
{<<"timestamp">>, erlang:system_time(millisecond)}, {<<"timestamp">>, erlang:system_time(millisecond)},