diff --git a/apps/emqx/src/proto/emqx_cm_proto_v2.erl b/apps/emqx/src/proto/emqx_cm_proto_v2.erl index b1eebd2d4..29dec50cd 100644 --- a/apps/emqx/src/proto/emqx_cm_proto_v2.erl +++ b/apps/emqx/src/proto/emqx_cm_proto_v2.erl @@ -48,11 +48,13 @@ kickout_client(Node, ClientId) -> lookup_client(Node, Key) -> rpc:call(Node, emqx_cm, lookup_client, [Key]). --spec get_chan_stats(emqx_types:clientid(), emqx_cm:chan_pid()) -> emqx_types:stats() | {badrpc, _}. +-spec get_chan_stats(emqx_types:clientid(), emqx_cm:chan_pid()) -> + emqx_types:stats() | undefined | {badrpc, _}. get_chan_stats(ClientId, ChanPid) -> rpc:call(node(ChanPid), emqx_cm, do_get_chan_stats, [ClientId, ChanPid], ?T_GET_INFO * 2). --spec get_chan_info(emqx_types:clientid(), emqx_cm:chan_pid()) -> emqx_types:infos() | {badrpc, _}. +-spec get_chan_info(emqx_types:clientid(), emqx_cm:chan_pid()) -> + emqx_types:infos() | undefined | {badrpc, _}. get_chan_info(ClientId, ChanPid) -> rpc:call(node(ChanPid), emqx_cm, do_get_chan_info, [ClientId, ChanPid], ?T_GET_INFO * 2).