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

Ensure check_passed result for leader health internal calls)

This commit is contained in:
Ayanda Dube 2025-01-13 16:59:55 +00:00
parent 1084179a2c
commit 68739a6bd2
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/leader_health_check_command.ex vendored
View File

@ -53,7 +53,7 @@ defmodule RabbitMQ.CLI.Queues.Commands.LeaderHealthCheckCommand do
end end
def output({:error, unhealthy_queues}, %{node: node_name, formatter: "json"}) when is_list(unhealthy_queues) do def output({:error, unhealthy_queues}, %{node: node_name, formatter: "json"}) when is_list(unhealthy_queues) do
{:error, :check_failed, {:ok, :check_passed,
%{ %{
"result" => "error", "result" => "error",
"queues" => unhealthy_queues, "queues" => unhealthy_queues,
@ -62,13 +62,13 @@ defmodule RabbitMQ.CLI.Queues.Commands.LeaderHealthCheckCommand do
end end
def output({:error, unhealthy_queues}, %{silent: true}) when is_list(unhealthy_queues) do def output({:error, unhealthy_queues}, %{silent: true}) when is_list(unhealthy_queues) do
{:error, :check_failed} {:ok, :check_passed}
end end
def output({:error, unhealthy_queues}, %{vhost: _vhost}) when is_list(unhealthy_queues) do def output({:error, unhealthy_queues}, %{vhost: _vhost}) when is_list(unhealthy_queues) do
lines = queue_lines(unhealthy_queues) lines = queue_lines(unhealthy_queues)
{:error, :check_failed, Enum.join(lines, line_separator())} {:ok, :check_passed, Enum.join(lines, line_separator())}
end end
def formatter(), do: RabbitMQ.CLI.Formatters.PrettyTable def formatter(), do: RabbitMQ.CLI.Formatters.PrettyTable