64 lines
2.2 KiB
Erlang
64 lines
2.2 KiB
Erlang
%%--------------------------------------------------------------------
|
|
%% Copyright (c) 2020-2024 EMQ Technologies Co., Ltd. All Rights Reserved.
|
|
%%
|
|
%% Licensed under the Apache License, Version 2.0 (the "License");
|
|
%% you may not use this file except in compliance with the License.
|
|
%% You may obtain a copy of the License at
|
|
%%
|
|
%% http://www.apache.org/licenses/LICENSE-2.0
|
|
%%
|
|
%% Unless required by applicable law or agreed to in writing, software
|
|
%% distributed under the License is distributed on an "AS IS" BASIS,
|
|
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
%% See the License for the specific language governing permissions and
|
|
%% limitations under the License.
|
|
%%--------------------------------------------------------------------
|
|
|
|
-module(emqx_observer_cli).
|
|
|
|
-export([
|
|
enable/0,
|
|
disable/0
|
|
]).
|
|
|
|
-export([cmd/1]).
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% enable/disable
|
|
%%--------------------------------------------------------------------
|
|
enable() ->
|
|
emqx_ctl:register_command(observer, {?MODULE, cmd}, []).
|
|
|
|
disable() ->
|
|
emqx_ctl:unregister_command(observer).
|
|
|
|
cmd(["status"]) ->
|
|
observer_cli:start();
|
|
cmd(["bin_leak"]) ->
|
|
lists:foreach(
|
|
fun(Row) -> emqx_ctl:print("~p~n", [Row]) end,
|
|
recon:bin_leak(100)
|
|
);
|
|
cmd(["load", Mod]) ->
|
|
case nodes() of
|
|
[] ->
|
|
emqx_ctl:print("No other nodes in the cluster~n");
|
|
Nodes ->
|
|
case emqx_utils:safe_to_existing_atom(Mod) of
|
|
{ok, Module} ->
|
|
Res = recon:remote_load(Nodes, Module),
|
|
emqx_ctl:print("Loaded ~p module on ~p: ~p~n", [Module, Nodes, Res]);
|
|
{error, Reason} ->
|
|
emqx_ctl:print("Module(~s) not found: ~p~n", [Mod, Reason])
|
|
end
|
|
end;
|
|
cmd(_) ->
|
|
emqx_ctl:usage([
|
|
{"observer status", "Start observer in the current console"},
|
|
{"observer bin_leak",
|
|
"Force all processes to perform garbage collection "
|
|
"and prints the top-100 processes that freed the "
|
|
"biggest amount of binaries, potentially highlighting leaks."},
|
|
{"observer load Mod", "Enhanced module synchronization across all cluster nodes"}
|
|
]).
|