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

fix ctl api

This commit is contained in:
Ery Lee 2012-12-26 14:36:39 +08:00
parent 50baba2cf6
commit e7ba96b263
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/emqtt_ctl.erl
View File

@ -2,9 +2,13 @@
-include("emqtt.hrl"). -include("emqtt.hrl").
-compile(export_all). -export([status/1,
cluster_info/1,
cluster/1,
add_user/1,
delete_user/1]).
status() -> status([]) ->
{InternalStatus, _ProvidedStatus} = init:get_status(), {InternalStatus, _ProvidedStatus} = init:get_status(),
?PRINT("Node ~p is ~p~n", [node(), InternalStatus]), ?PRINT("Node ~p is ~p~n", [node(), InternalStatus]),
case lists:keysearch(emqtt, 1, application:which_applications()) of case lists:keysearch(emqtt, 1, application:which_applications()) of
@ -14,11 +18,11 @@ status() ->
?PRINT_MSG("emqtt is running~n") ?PRINT_MSG("emqtt is running~n")
end. end.
cluster_info() -> cluster_info([]) ->
Nodes = [node()|nodes()], Nodes = [node()|nodes()],
?PRINT("cluster nodes: ~p~n", [Nodes]). ?PRINT("cluster nodes: ~p~n", [Nodes]).
cluster(Node) -> cluster([Node]) ->
case net_adm:ping(list_to_atom(Node)) of case net_adm:ping(list_to_atom(Node)) of
pong -> pong ->
?PRINT("cluster with ~p successfully.~n", [Node]); ?PRINT("cluster with ~p successfully.~n", [Node]);
@ -26,8 +30,8 @@ cluster(Node) ->
?PRINT("failed to cluster with ~p~n", [Node]) ?PRINT("failed to cluster with ~p~n", [Node])
end. end.
add_user(Username, Password) -> add_user([Username, Password]) ->
?PRINT("~p", [emqtt_auth:add(list_to_binary(Username), list_to_binary(Password))]). ?PRINT("~p", [emqtt_auth:add(list_to_binary(Username), list_to_binary(Password))]).
delete_user(Username) -> delete_user([Username]) ->
?PRINT("~p", [emqtt_auth:delete(list_to_binary(Username))]). ?PRINT("~p", [emqtt_auth:delete(list_to_binary(Username))]).