New command group: replication

deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/cancel_sync_queue_command.ex

@@ -37,7 +37,7 @@ defmodule RabbitMQ.CLI.Ctl.Commands.CancelSyncQueueCommand do
 
   def usage, do: "cancel_sync_queue [-p <vhost>] queue"
 
-  def help_section(), do: :queues
+  def help_section(), do: :replication
 
   def description(), do: "Instructs a synchronising mirrored queue to stop synchronising itself"
 

deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/help_command.ex

@@ -172,6 +172,7 @@ defmodule RabbitMQ.CLI.Ctl.Commands.HelpCommand do
           :help -> 1
           :node_management -> 2
           :cluster_management -> 3
+          :replication -> 3
           :user_management -> 4
           :access_control -> 5
           :observability_and_health_checks -> 6
@@ -204,6 +205,8 @@ defmodule RabbitMQ.CLI.Ctl.Commands.HelpCommand do
         "Users"
       :cluster_management ->
         "Cluster"
+      :replication ->
+        "Replication"
       :node_management ->
         "Nodes"
       :queues ->

deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/sync_queue_command.ex

@@ -37,7 +37,7 @@ defmodule RabbitMQ.CLI.Ctl.Commands.SyncQueueCommand do
 
   def usage, do: "sync_queue [-p <vhost>] queue"
 
-  def help_section(), do: :queues
+  def help_section(), do: :replication
 
   def description(), do: "Instructs a mirrored queue with unsynchronised mirrors (follower replicas) to synchronise them"
 

deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member_command.ex

@@ -41,11 +41,13 @@ defmodule RabbitMQ.CLI.Queues.Commands.AddMemberCommand do
 
   use RabbitMQ.CLI.DefaultOutput
 
+  def usage, do: "add_member [-p <vhost>] <queuename> <node>"
+
+  def help_section, do: :replication
+
   def description, do: "Adds a quorum queue member (replica) for a queue on the given node."
 
   def banner([name, node], _) do
     "Adding member #{node} to quorum queue #{name} cluster..."
   end
-
-  def usage, do: "add_member [-p <vhost>] <queuename> <node>"
 end

deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/delete_member_command.ex

@@ -41,11 +41,13 @@ defmodule RabbitMQ.CLI.Queues.Commands.DeleteMemberCommand do
 
   use RabbitMQ.CLI.DefaultOutput
 
+  def usage, do: "delete_member [-p <vhost>] <queuename> <node>"
+
+  def help_section, do: :replication
+
   def description, do: "Removes a quorum queue member (replica) for a queue on the given node."
 
   def banner([name, node], _) do
     "Deleting member #{node} from quorum queue #{name} cluster..."
   end
-
-  def usage, do: "delete_member [-p <vhost>] <queuename> <node>"
 end

deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/grow_command.ex

@@ -81,14 +81,16 @@ defmodule RabbitMQ.CLI.Queues.Commands.GrowCommand do
 
   def formatter(), do: RabbitMQ.CLI.Formatters.Table
 
+  def usage, do: "grow <node> <all | even> [--vhost-pattern <pattern>] [--queue-pattern <pattern>]"
+
+  def help_section, do: :cluster_management
+
   def description, do: "Grows quorum queue clusters by adding a member (replica) to all matching quorum queues on the given node."
 
   def banner([node, strategy], _) do
     "Growing #{strategy} quorum queues on #{node}..."
   end
 
-  def usage, do: "grow <node> <all | even> [--vhost-pattern <pattern>] [--queue-pattern <pattern>]"
-
   #
   # Implementation
   #

deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/shrink_command.ex

@@ -52,14 +52,16 @@ defmodule RabbitMQ.CLI.Queues.Commands.ShrinkCommand do
 
   def formatter(), do: RabbitMQ.CLI.Formatters.Table
 
+  def usage, do: "shrink <node> [--errors-only]"
+
+  def help_section, do: :cluster_management
+
   def description, do: "Shrinks quorum queue clusters by removing any members (replicas) on the given node."
 
   def banner([node], _) do
     "Shrinking quorum queues on #{node}..."
   end
 
-  def usage, do: "shrink <node> [--errors-only]"
-
   #
   # Implementation
   #