Make it easier to list plugins enabled across the entire cluster

Author: michaelklishin

CHANGELOG.md

@@ -2,7 +2,10 @@
 
 ## v0.62.0 (in development)
 
-No changes yet.
+### Enhancements
+
+ * `Client#list_all_cluster_plugins` is a new function that returns a combined set of plugins enabled across all cluster nodes
+ * `Client#list_node_plugins` is a new function that returns the list of plugins enabled on a specific node
 
 ## v0.61.0 (Oct 8, 2025)
 

src/api/nodes.rs

@@ -46,4 +46,28 @@ where
         let response = response.json().await?;
         Ok(response)
     }
+
+    /// Returns a unique set of plugins enabled on all cluster nodes.
+    /// See [RabbitMQ Plugins Guide](https://www.rabbitmq.com/docs/plugins) to learn more.
+    pub async fn list_all_cluster_plugins(&self) -> Result<responses::PluginList> {
+        let nodes = self.list_nodes().await?;
+
+        let mut aggregated_set: Vec<String> = nodes
+            .into_iter()
+            .flat_map(|node| node.enabled_plugins.into_iter())
+            .collect::<std::collections::HashSet<_>>()
+            .into_iter()
+            .collect();
+
+        aggregated_set.sort();
+        Ok(responses::PluginList(aggregated_set))
+    }
+
+    /// Returns the list of plugins enabled on a specific cluster node.
+    /// This is a convenience method equivalent to `get_node_info(name).enabled_plugins`.
+    /// See [RabbitMQ Plugins Guide](https://www.rabbitmq.com/docs/plugins) to learn more.
+    pub async fn list_node_plugins(&self, name: &str) -> Result<responses::PluginList> {
+        let node = self.get_node_info(name).await?;
+        Ok(node.enabled_plugins)
+    }
 }

src/blocking_api/nodes.rs

@@ -41,4 +41,28 @@ where
         let response = response.json()?;
         Ok(response)
     }
+
+    /// Returns a unique set of plugins enabled on all cluster nodes.
+    /// See [RabbitMQ Plugins Guide](https://www.rabbitmq.com/docs/plugins) to learn more.
+    pub fn list_all_cluster_plugins(&self) -> Result<responses::PluginList> {
+        let nodes = self.list_nodes()?;
+
+        let mut aggregated_set: Vec<String> = nodes
+            .into_iter()
+            .flat_map(|node| node.enabled_plugins.into_iter())
+            .collect::<std::collections::HashSet<_>>()
+            .into_iter()
+            .collect();
+
+        aggregated_set.sort();
+        Ok(responses::PluginList(aggregated_set))
+    }
+
+    /// Returns the list of plugins enabled on a specific cluster node.
+    /// This is a convenience method equivalent to `get_node_info(name).enabled_plugins`.
+    /// See [RabbitMQ Plugins Guide](https://www.rabbitmq.com/docs/plugins) to learn more.
+    pub fn list_node_plugins(&self, name: &str) -> Result<responses::PluginList> {
+        let node = self.get_node_info(name)?;
+        Ok(node.enabled_plugins)
+    }
 }

tests/async_node_tests.rs

@@ -64,3 +64,31 @@ async fn test_async_get_node_memory_footprint() {
         }
     }
 }
+
+#[tokio::test]
+async fn test_async_list_all_cluster_plugins() {
+    let endpoint = endpoint();
+    let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+    let result = rc.list_all_cluster_plugins().await;
+
+    assert!(result.is_ok());
+    let plugins = result.unwrap();
+    assert!(!plugins.is_empty());
+    // The management plugin should be enabled since we're using the HTTP API
+    assert!(plugins.contains("rabbitmq_management"));
+}
+
+#[tokio::test]
+async fn test_async_list_node_plugins() {
+    let endpoint = endpoint();
+    let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+    let nodes = rc.list_nodes().await.unwrap();
+    let name = nodes.first().unwrap().name.clone();
+    let result = rc.list_node_plugins(&name).await;
+
+    assert!(result.is_ok());
+    let plugins = result.unwrap();
+    assert!(!plugins.is_empty());
+    // The management plugin should be enabled since we're using the HTTP API
+    assert!(plugins.contains("rabbitmq_management"));
+}

tests/blocking_node_tests.rs

@@ -64,3 +64,31 @@ fn test_blocking_get_node_memory_footprint() {
         }
     }
 }
+
+#[test]
+fn test_blocking_list_all_cluster_plugins() {
+    let endpoint = endpoint();
+    let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+    let result = rc.list_all_cluster_plugins();
+
+    assert!(result.is_ok());
+    let plugins = result.unwrap();
+    assert!(!plugins.is_empty());
+    // The management plugin should be enabled since we're using the HTTP API
+    assert!(plugins.contains("rabbitmq_management"));
+}
+
+#[test]
+fn test_blocking_list_node_plugins() {
+    let endpoint = endpoint();
+    let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+    let nodes = rc.list_nodes().unwrap();
+    let name = nodes.first().unwrap().name.clone();
+    let result = rc.list_node_plugins(&name);
+
+    assert!(result.is_ok());
+    let plugins = result.unwrap();
+    assert!(!plugins.is_empty());
+    // The management plugin should be enabled since we're using the HTTP API
+    assert!(plugins.contains("rabbitmq_management"));
+}