root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Add CQ and QQ Observer CLI plugins from boot steps 

Do not hard code them, also preserve user-provided plugins list
Type fix by @kura
This commit is contained in:
Iliia Khaprov 2025-05-22 10:21:32 +02:00
parent 6dd7447b92
commit 2d029649a2
No known key found for this signature in database
GPG Key ID: 4DCFF8F358E49AED
3 changed files with 22 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/rabbit/src/rabbit_observer_cli.erl vendored
View File

@ -10,10 +10,8 @@
-export([init/0, add_plugin/1]). -export([init/0, add_plugin/1]).
init() -> init() ->
application:set_env(observer_cli, plugins, [ %% prepare observer_cli.plugins for add_plugin/1
rabbit_observer_cli_classic_queues:plugin_info(), application:set_env(observer_cli, plugins, application:get_env(observer_cli, plugins, [])).
rabbit_observer_cli_quorum_queues:plugin_info()
]).
%% must be executed after observer_cli boot_step %% must be executed after observer_cli boot_step
add_plugin(PluginInfo) -> add_plugin(PluginInfo) ->

11
deps/rabbit/src/rabbit_observer_cli_classic_queues.erl vendored
View File

@ -7,11 +7,20 @@
-module(rabbit_observer_cli_classic_queues). -module(rabbit_observer_cli_classic_queues).
-export([plugin_info/0]). -export([add_plugin/0, plugin_info/0]).
-export([attributes/1, sheet_header/0, sheet_body/1]). -export([attributes/1, sheet_header/0, sheet_body/1]).
-include_lib("rabbit_common/include/rabbit.hrl"). -include_lib("rabbit_common/include/rabbit.hrl").
-rabbit_boot_step({?MODULE,
[{description, "Classic queues observer_cli plugin"},
{mfa, {?MODULE, add_plugin, []}},
{requires, [rabbit_observer_cli]},
{enables, routing_ready}]}).
add_plugin() ->
rabbit_observer_cli:add_plugin(plugin_info()).
plugin_info() -> plugin_info() ->
#{ #{
module => rabbit_observer_cli_classic_queues, module => rabbit_observer_cli_classic_queues,

11
deps/rabbit/src/rabbit_observer_cli_quorum_queues.erl vendored
View File

@ -7,11 +7,20 @@
-module(rabbit_observer_cli_quorum_queues). -module(rabbit_observer_cli_quorum_queues).
-export([plugin_info/0]). -export([add_plugin/0, plugin_info/0]).
-export([attributes/1, sheet_header/0, sheet_body/1]). -export([attributes/1, sheet_header/0, sheet_body/1]).
-include_lib("rabbit_common/include/rabbit.hrl"). -include_lib("rabbit_common/include/rabbit.hrl").
-rabbit_boot_step({?MODULE,
[{description, "Quorum queues observer_cli plugin"},
{mfa, {?MODULE, add_plugin, []}},
{requires, [rabbit_observer_cli]},
{enables, routing_ready}]}).
add_plugin() ->
rabbit_observer_cli:add_plugin(plugin_info()).
plugin_info() -> plugin_info() ->
#{ #{
module => rabbit_observer_cli_quorum_queues, module => rabbit_observer_cli_quorum_queues,