Update kick_client API
This commit is contained in:
parent
aeec7804f9
commit
f6b9ce84e5
|
@ -339,6 +339,4 @@ any_to_string(A) when is_atom(A) ->
|
|||
any_to_string(B) when is_binary(B) ->
|
||||
binary_to_list(B);
|
||||
any_to_string(L) when is_list(L) ->
|
||||
L.
|
||||
|
||||
|
||||
L.
|
|
@ -24,7 +24,7 @@
|
|||
-http_api({"^nodes/(.+?)/clients/?$", 'GET', client_list, []}).
|
||||
-http_api({"^nodes/(.+?)/clients/(.+?)/?$", 'GET',client_list, []}).
|
||||
-http_api({"^clients/(.+?)/?$", 'GET', client, []}).
|
||||
-http_api({"^kick_client/(.+?)/?$", 'PUT', kick_client, []}).
|
||||
-http_api({"^clients/(.+?)/?$", 'DELETE', kick_client, []}).
|
||||
-http_api({"^clean_acl_cache/(.+?)/?$", 'PUT', clean_acl_cache, [{<<"topic">>, binary}]}).
|
||||
|
||||
-http_api({"^routes?$", 'GET', route_list, []}).
|
||||
|
@ -112,7 +112,7 @@ client_list('GET', Params, Node, Key) ->
|
|||
Data = emqttd_mgmt:client_list(l2a(Node), l2b(Key), PageNo, PageSize),
|
||||
{ok, [{objects, [client_row(Row) || Row <- Data]}]}.
|
||||
|
||||
kick_client('PUT', _Params, Key) ->
|
||||
kick_client('DELETE', _Params, Key) ->
|
||||
case emqttd_mgmt:kick_client(l2b(Key)) of
|
||||
true -> {ok, []};
|
||||
false -> {error, [{code, ?ERROR12}]}
|
||||
|
@ -448,4 +448,4 @@ b2l(B) -> binary_to_list(B).
|
|||
page_params(Params) ->
|
||||
PageNo = int(proplists:get_value("curr_page", Params, "1")),
|
||||
PageSize = int(proplists:get_value("page_size", Params, "20")),
|
||||
{PageNo, PageSize}.
|
||||
{PageNo, PageSize}.
|
||||
|
|
Loading…
Reference in New Issue