New command group: plugins

Author: michaelklishin

CHANGELOG.md

@@ -2,7 +2,21 @@
 
 ## v2.16.0 (in development)
 
-No changes yet.
+### Enhancements
+
+* `plugins` is a new command group for listing enabled plugins:
+
+  ```shell
+  # List plugins across all cluster nodes
+  rabbitmqadmin plugins list_all
+
+  # List plugins on a specific node
+  rabbitmqadmin plugins list_on_node --node rabbit@hostname
+  ```
+
+### Upgrades
+
+* RabbitMQ HTTP API client was upgraded to [`0.62.0`](https://github.com/michaelklishin/rabbitmq-http-api-rs/releases/tag/v0.62.0)
 
 
 ## v2.15.0 (Sep 30, 2025)

src/cli.rs

@@ -252,6 +252,17 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
         .subcommand_value_name("permission")
         .arg_required_else_help(true)
         .subcommands(permissions_subcommands(pre_flight_settings.clone()));
+    let plugins_group = Command::new("plugins")
+        .about("List enabled plugins")
+        .infer_subcommands(pre_flight_settings.infer_subcommands)
+        .infer_long_args(pre_flight_settings.infer_long_options)
+        .after_help(color_print::cformat!(
+            "<bold>Doc guide</bold>: {}",
+            PLUGIN_GUIDE_URL
+        ))
+        .subcommand_value_name("plugin")
+        .arg_required_else_help(true)
+        .subcommands(plugins_subcommands(pre_flight_settings.clone()));
     let policies_group = Command::new("policies")
         .about("Operations on policies")
         .infer_subcommands(pre_flight_settings.infer_subcommands)
@@ -398,6 +409,7 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
         parameters_group,
         passwords_group,
         permissions_group,
+        plugins_group,
         policies_group,
         publish_group,
         purge_group,
@@ -2797,6 +2809,36 @@ pub fn deprecated_features_subcommands(pre_flight_settings: PreFlightSettings) -
         .collect()
 }
 
+pub fn plugins_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
+    let list_all_cmd = Command::new("list_all")
+        .about("Lists plugins across all cluster nodes")
+        .after_help(color_print::cformat!(
+            "<bold>Doc guide</bold>: {}",
+            PLUGIN_GUIDE_URL
+        ));
+
+    let list_on_node_cmd = Command::new("list_on_node")
+        .about("Lists plugins enabled on a specific node")
+        .arg(
+            Arg::new("node")
+                .long("node")
+                .help("target node, must be a cluster member")
+                .required(true),
+        )
+        .after_help(color_print::cformat!(
+            "<bold>Doc guide</bold>: {}",
+            PLUGIN_GUIDE_URL
+        ));
+
+    [
+        list_all_cmd,
+        list_on_node_cmd,
+    ]
+    .into_iter()
+    .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
+    .collect()
+}
+
 pub fn nodes_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
     let list_cmd = Command::new("list")
         .long_about("Lists cluster nodes")

src/commands.rs

@@ -46,6 +46,7 @@ use serde_json::Value;
 use std::fs;
 use std::io;
 use std::process;
+use tabled::Tabled;
 
 type APIClient = Client<String, String, String>;
 
@@ -1090,6 +1091,52 @@ pub fn list_deprecated_features_in_use(
     client.list_deprecated_features_in_use()
 }
 
+//
+// Plugins
+//
+
+#[derive(Debug, Clone, Tabled)]
+pub struct PluginOnNode {
+    pub node: String,
+    pub name: String,
+    pub state: String,
+}
+
+pub fn list_plugins_on_node(
+    client: APIClient,
+    command_args: &ArgMatches,
+) -> ClientResult<Vec<PluginOnNode>> {
+    let node = command_args.get_one::<String>("node").cloned().unwrap();
+    let plugins = client.list_node_plugins(&node)?;
+
+    Ok(plugins
+        .into_iter()
+        .map(|plugin_name| PluginOnNode {
+            node: node.clone(),
+            name: plugin_name,
+            state: "Enabled".to_string(),
+        })
+        .collect())
+}
+
+pub fn list_plugins_across_cluster(client: APIClient) -> ClientResult<Vec<PluginOnNode>> {
+    let nodes = client.list_nodes()?;
+    let mut result = Vec::new();
+
+    for node in nodes {
+        let plugins = client.list_node_plugins(&node.name)?;
+        for plugin_name in plugins {
+            result.push(PluginOnNode {
+                node: node.name.clone(),
+                name: plugin_name,
+                state: "Enabled".to_string(),
+            });
+        }
+    }
+
+    Ok(result)
+}
+
 //
 // Declaration of core resources
 //

src/main.rs

@@ -823,6 +823,14 @@ fn dispatch_common_subcommand(
             let result = commands::show_memory_breakdown(client, second_level_args);
             res_handler.memory_breakdown_in_percent_result(result)
         }
+        ("plugins", "list_all") => {
+            let result = commands::list_plugins_across_cluster(client);
+            res_handler.tabular_result(result)
+        }
+        ("plugins", "list_on_node") => {
+            let result = commands::list_plugins_on_node(client, second_level_args);
+            res_handler.tabular_result(result)
+        }
         ("operator_policies", "declare") => {
             let result = commands::declare_operator_policy(client, &vhost, second_level_args);
             res_handler.no_output_on_success(result);

src/static_urls.rs

@@ -60,6 +60,7 @@ pub(crate) const OPERATOR_POLICY_GUIDE_URL: &str =
     "https://rabbitmq.com/docs/parameters#operator-policies";
 pub(crate) const USER_LIMIT_GUIDE_URL: &str = "https://rabbitmq.com/docs/user-limits";
 pub(crate) const PASSWORD_GUIDE_URL: &str = "https://rabbitmq.com/docs/passwords";
+pub(crate) const PLUGIN_GUIDE_URL: &str = "https://rabbitmq.com/docs/plugins";
 pub(crate) const SHOVEL_GUIDE_URL: &str = "https://rabbitmq.com/docs/shovel";
 pub(crate) const FEDERATION_GUIDE_URL: &str = "https://rabbitmq.com/docs/federation";
 pub(crate) const FEDERATED_QUEUES_GUIDE_URL: &str = "https://rabbitmq.com/docs/federated-queues";

tests/plugins_tests.rs

@@ -0,0 +1,36 @@
+// Copyright (C) 2023-2025 RabbitMQ Core Team (teamrabbitmq@gmail.com)
+//
+// 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.
+
+use std::error::Error;
+mod test_helpers;
+use crate::test_helpers::*;
+
+#[test]
+fn test_plugins_list_all_succeeds() -> Result<(), Box<dyn Error>> {
+    run_succeeds(["plugins", "list_all"]).stdout(output_includes("rabbitmq_management"));
+
+    Ok(())
+}
+
+#[test]
+fn test_plugins_list_on_node_succeeds() -> Result<(), Box<dyn Error>> {
+    let rc = api_client();
+    let nodes = rc.list_nodes()?;
+    let first = nodes.first().unwrap();
+
+    run_succeeds(["plugins", "list_on_node", "--node", first.name.as_str()])
+        .stdout(output_includes("rabbitmq_management"));
+
+    Ok(())
+}