root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Drive-by change: improve wording used by 'rabbitmq-queues rebalance'

This commit is contained in:
Michael Klishin 2021-02-09 21:02:52 +03:00
parent 686d462035
commit 68c04358a5
No known key found for this signature in database
GPG Key ID: E80EDCFA0CDB21EE
2 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbit/src/rabbit_amqqueue.erl vendored
View File

@ -498,7 +498,7 @@ maybe_migrate(ByNode, _, []) ->
?amqqueue_is_classic(Q) ?amqqueue_is_classic(Q)
end, V), end, V),
[[{<<"Node name">>, K}, {<<"Number of quorum queues">>, length(QQs)}, [[{<<"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)}; end, [], ByNode)};
maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) -> maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) ->
case maps:get(N, ByNode, []) of case maps:get(N, ByNode, []) of

16
deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex vendored
View File

@ -75,10 +75,18 @@ defmodule RabbitMQ.CLI.Queues.Commands.RebalanceCommand do
def help_section, do: :cluster_management 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([type], _) do def banner([:all], _) do
"Rebalancing #{type} queues..." "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
"Re-balancing leaders of #{type} queues..."
end end
end end