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