diff options
author | Michael Klishin <michael@clojurewerkz.org> | 2021-02-09 21:02:52 +0300 |
---|---|---|
committer | Michael Klishin <michael@clojurewerkz.org> | 2021-02-09 21:02:52 +0300 |
commit | 68c04358a5e092d019ad9b6699a9f2010f6221c5 (patch) | |
tree | 548ea41592ff11cbf5502f4398091cdb5a071f71 | |
parent | 686d4620350c6fee2100ce0fba3c3a8bf86c3b49 (diff) | |
download | rabbitmq-server-git-rabbitmq-server-2796.tar.gz |
Drive-by change: improve wording used by 'rabbitmq-queues rebalance'rabbitmq-server-2796
-rw-r--r-- | deps/rabbit/src/rabbit_amqqueue.erl | 2 | ||||
-rw-r--r-- | deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex | 14 |
2 files changed, 12 insertions, 4 deletions
diff --git a/deps/rabbit/src/rabbit_amqqueue.erl b/deps/rabbit/src/rabbit_amqqueue.erl index 5536b35414..a8422b3da3 100644 --- a/deps/rabbit/src/rabbit_amqqueue.erl +++ b/deps/rabbit/src/rabbit_amqqueue.erl @@ -498,7 +498,7 @@ maybe_migrate(ByNode, _, []) -> ?amqqueue_is_classic(Q) end, V), [[{<<"Node name">>, K}, {<<"Number of quorum queues">>, length(QQs)}, - {<<"Number of classic queues">>, length(CQs)}] | Acc] + {<<"Number of replicated classic queues">>, length(CQs)}] | Acc] end, [], ByNode)}; maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) -> case maps:get(N, ByNode, []) of diff --git a/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex b/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex index 1416a7c570..1c7f44b2de 100644 --- a/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex +++ b/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex @@ -75,10 +75,18 @@ defmodule RabbitMQ.CLI.Queues.Commands.RebalanceCommand do def help_section, do: :cluster_management - def description, do: "Rebalances queues." + def description, do: "Re-balances leaders of replicated queues across up-and-running cluster nodes" + def banner([:all], _) do + "Re-balancing leaders of all replicated queues..." + end + def banner([:classic], _) do + "Re-balancing leaders of replicated (mirrored, non-exclusive) classic queues..." + end + def banner([:quorum], _) do + "Re-balancing leaders of quorum queues..." + end def banner([type], _) do - "Rebalancing #{type} queues..." + "Re-balancing leaders of #{type} queues..." end - end |