@@ -49,17 +49,7 @@ defmodule RabbitMQ.CLI.Queues.Commands.GrowCommand do
49
49
{ :validation_failure , "strategy '#{ s } ' is not recognised." }
50
50
end
51
51
52
- def do_validate ( [ n , _ ] , _ )
53
- when ( is_integer ( n ) and n <= 0 ) do
54
- { :validation_failure , "target quorum cluster size '#{ n } ' must be greater than 0." }
55
- end
56
-
57
- def do_validate ( [ n , _ ] , % { membership: m } )
58
- when ( is_integer ( n ) and not ( m == "voter" or m == "promotable" ) ) do
59
- { :validation_failure , "voter status '#{ m } ' must be 'voter' or 'promotable' to grow to target quorum cluster size '#{ n } '." }
60
- end
61
-
62
- def do_validate ( _ , % { membership: m } )
52
+ def validate ( _ , % { membership: m } )
63
53
when not ( m == "promotable" or
64
54
m == "non_voter" or
65
55
m == "voter" ) do
@@ -88,24 +78,15 @@ defmodule RabbitMQ.CLI.Queues.Commands.GrowCommand do
88
78
)
89
79
end
90
80
91
- def run ( [ node_or_quorum_cluster_size , strategy ] , % {
81
+ def run ( [ node , strategy ] , % {
92
82
node: node_name ,
93
83
vhost_pattern: vhost_pat ,
94
84
queue_pattern: queue_pat ,
95
85
membership: membership ,
96
86
errors_only: errors_only
97
87
} ) do
98
88
99
- node_or_quorum_cluster_size =
100
- case Integer . parse ( node_or_quorum_cluster_size ) do
101
- { cluster_size , _ } when is_integer ( cluster_size ) ->
102
- cluster_size
103
-
104
- :error ->
105
- to_atom ( node_or_quorum_cluster_size )
106
- end
107
-
108
- args = [ node_or_quorum_cluster_size , vhost_pat , queue_pat , to_atom ( strategy ) ]
89
+ args = [ to_atom ( node ) , vhost_pat , queue_pat , to_atom ( strategy ) ]
109
90
110
91
args =
111
92
case to_atom ( membership ) do
@@ -146,11 +127,11 @@ defmodule RabbitMQ.CLI.Queues.Commands.GrowCommand do
146
127
147
128
def usage ,
148
129
do:
149
- "grow <node | quorum_cluster_size > <all | even> [--vhost-pattern <pattern>] [--queue-pattern <pattern>] [--membership <promotable|voter>]"
130
+ "grow <node> <all | even> [--vhost-pattern <pattern>] [--queue-pattern <pattern>] [--membership <promotable|voter>]"
150
131
151
132
def usage_additional do
152
133
[
153
- [ "<node | quorum_cluster_size >" , "node name to place replicas on or desired quorum cluster size " ] ,
134
+ [ "<node>" , "node name to place replicas on" ] ,
154
135
[
155
136
"<all | even>" ,
156
137
"add a member for all matching queues or just those whose membership count is an even number"
0 commit comments