New command group: channels

Author: michaelklishin

CHANGELOG.md

@@ -5,6 +5,7 @@
 ### Enhancements
 
  * `connections` is a new command group for operations on connections
+ * `channels` is a new command group for operations on channels
  * `policies set` and `policies update` are two new aliases for `policies declare`. The former follows the naming
    used by `rabbitmqctl` and the latter reflects the fact that the command can be used to update an existing policy,
    in particular, to override its definition

src/cli.rs

@@ -51,6 +51,11 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
         .infer_long_args(pre_flight_settings.infer_long_options)
         .subcommand_value_name("binding")
         .subcommands(binding_subcommands(pre_flight_settings.clone()));
+    let channels_group = Command::new("channels")
+        .about("Operations on channels")
+        .infer_subcommands(pre_flight_settings.infer_subcommands)
+        .infer_long_args(pre_flight_settings.infer_long_options)
+        .subcommands(channels_subcommands(pre_flight_settings.clone()));
     let close_group = Command::new("close")
         .about("Closes connections")
         .infer_subcommands(pre_flight_settings.infer_subcommands)
@@ -287,6 +292,7 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
 
     let command_groups = [
         bindings_group,
+        channels_group,
         close_group,
         connections_group,
         declare_group,
@@ -1848,6 +1854,17 @@ fn close_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 2] {
         .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
 }
 
+fn channels_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 1] {
+    let list_cmd = Command::new("list")
+        .long_about("Lists all channels across all virtual hosts")
+        .after_help(color_print::cformat!(
+            "<bold>Doc guide</bold>: {}",
+            "https://www.rabbitmq.com/docs/channels"
+        ));
+
+    [list_cmd].map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
+}
+
 fn connections_subcommands(pre_flight_settings: PreFlightSettings) -> [Command; 4] {
     let close_connection = Command::new("close")
         .about("Closes a client connection")

src/main.rs

@@ -12,6 +12,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 #![allow(clippy::result_large_err)]
+#![allow(clippy::unnecessary_unwrap)]
+#![allow(clippy::collapsible_if)]
 
 use clap::ArgMatches;
 use errors::CommandRunError;
@@ -291,6 +293,10 @@ fn dispatch_common_subcommand(
             let result = commands::list_bindings(client);
             res_handler.tabular_result(result)
         }
+        ("channels", "list") => {
+            let result = commands::list_channels(client);
+            res_handler.tabular_result(result)
+        }
         ("close", "connection") => {
             let result = commands::close_connection(client, second_level_args);
             res_handler.no_output_on_success(result);

tests/channels_tests.rs

@@ -0,0 +1,30 @@
+// Copyright (C) 2023-2025 RabbitMQ Core Team ([email protected])
+//
+// 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.
+
+mod test_helpers;
+use crate::test_helpers::*;
+
+#[test]
+fn test_list_channels1() -> Result<(), Box<dyn std::error::Error>> {
+    run_succeeds(["channels", "list"]);
+
+    Ok(())
+}
+
+#[test]
+fn test_list_channels2() -> Result<(), Box<dyn std::error::Error>> {
+    run_succeeds(["list", "channels"]);
+
+    Ok(())
+}