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

Merge pull request #11596 from thalesmg/fix-typespec-typos-m-20230912 

fix: fix typespec typos
This commit is contained in:
Thales Macedo Garitezi 2023-09-15 09:24:42 -03:00 committed by GitHub
parent aace9215a4 6be0e14e8c
commit 2aae3856a3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_cm.erl
View File

@ -415,7 +415,7 @@ discard_session(ClientId) when is_binary(ClientId) ->
%% benefits nobody. %% benefits nobody.
-spec request_stepdown(Action, module(), pid()) -> -spec request_stepdown(Action, module(), pid()) ->
ok ok
| {ok, emqx_session:session() | list(emqx_type:deliver())} | {ok, emqx_session:session() | list(emqx_types:deliver())}
| {error, term()} | {error, term()}
when when
Action :: kick | discard | {takeover, 'begin'} | {takeover, 'end'}. Action :: kick | discard | {takeover, 'begin'} | {takeover, 'end'}.

4
apps/emqx/src/proto/emqx_cm_proto_v2.erl
View File

@ -70,8 +70,8 @@ takeover_session(ClientId, ChanPid) ->
rpc:call(node(ChanPid), emqx_cm, takeover_session, [ClientId, ChanPid], ?T_TAKEOVER * 2). rpc:call(node(ChanPid), emqx_cm, takeover_session, [ClientId, ChanPid], ?T_TAKEOVER * 2).
-spec takeover_finish(module(), emqx_cm:chan_pid()) -> -spec takeover_finish(module(), emqx_cm:chan_pid()) ->
{ok, emqx_type:takeover_data()} {ok, emqx_types:takeover_data()}
| {ok, list(emqx_type:deliver()), emqx_type:takeover_data()} | {ok, list(emqx_types:deliver())}
| {error, term()} | {error, term()}
| {badrpc, _}. | {badrpc, _}.
takeover_finish(ConnMod, ChanPid) -> takeover_finish(ConnMod, ChanPid) ->

2
apps/emqx_gateway/src/emqx_gateway_cm.erl
View File

@ -568,7 +568,7 @@ do_kick_session(GwName, Action, ClientId, ChanPid) ->
%% benefits nobody. %% benefits nobody.
-spec request_stepdown(Action, module(), pid()) -> -spec request_stepdown(Action, module(), pid()) ->
ok ok
| {ok, emqx_session:session() | list(emqx_type:deliver())} | {ok, emqx_session:session() | list(emqx_types:deliver())}
| {error, term()} | {error, term()}
when when
Action :: kick | discard | {takeover, 'begin'} | {takeover, 'end'}. Action :: kick | discard | {takeover, 'begin'} | {takeover, 'end'}.