@@ -28,11 +28,37 @@ defmodule RabbitMQ.CLI.Queues.Commands.LeaderHealthCheckCommand do
28
28
end
29
29
end
30
30
31
- def output ( :ok , % { formatter: "json" } ) do
32
- { :error , :check_passed }
31
+ def output ( :ok , % { node: node_name , formatter: "json" } ) do
32
+ { :ok ,
33
+ % {
34
+ "result" => "ok" ,
35
+ "message" =>
36
+ "Node #{ node_name } reported all quorum queue leaders as healthy"
37
+ } }
33
38
end
34
39
35
- def output ( { :error , unhealthy_queues } , % { vhost: _vhost , formatter: "json" } ) when is_list ( unhealthy_queues ) do
40
+ def output ( :ok , % { silent: true } ) do
41
+ { :ok , :check_passed }
42
+ end
43
+
44
+ def output ( :ok , % { node: node_name } ) do
45
+ { :ok , "Node #{ node_name } reported all quorum queue leaders as healthy" }
46
+ end
47
+
48
+ def output ( { :error , unhealthy_queues } , % { node: node_name , formatter: "json" } ) when is_list ( unhealthy_queues ) do
49
+ { :error , :check_failed ,
50
+ % {
51
+ "result" => "error" ,
52
+ "queues" => unhealthy_queues ,
53
+ "message" => "Node #{ node_name } reported unhealthy quorum queue leaders"
54
+ } }
55
+ end
56
+
57
+ def output ( { :error , unhealthy_queues } , % { silent: true } ) when is_list ( unhealthy_queues ) do
58
+ { :error , :check_failed }
59
+ end
60
+
61
+ def output ( { :error , unhealthy_queues } , % { vhost: _vhost } ) when is_list ( unhealthy_queues ) do
36
62
lines = queue_lines ( unhealthy_queues )
37
63
38
64
{ :error , :check_failed , Enum . join ( lines , line_separator ( ) ) }
0 commit comments