CLI: force_standalone_khepri_boot command

Author: dcorbacho

deps/rabbit/test/clustering_management_SUITE.erl

@@ -100,6 +100,11 @@ groups() ->
                                                  start_nodes_in_stop_order,
                                                  start_nodes_in_stop_order_with_force_boot
                                                 ]}
+                          ]},
+                         {clustered_3_nodes, [],
+                          [{cluster_size_3, [], [
+                                                 force_standalone_boot
+                                                ]}
                           ]}
                         ]}
     ].
@@ -1222,6 +1227,23 @@ start_nodes_in_stop_order_with_force_boot(Config) ->
     ok = rabbit_ct_broker_helpers:start_node(Config, Bunny),
     assert_clustered([Rabbit, Hare, Bunny]).
 
+%% TODO test force_standalone after restarting this last node
+force_standalone_boot(Config) ->
+    [Rabbit, Hare, Bunny] = cluster_members(Config),
+
+    assert_cluster_status({[Rabbit, Hare, Bunny], [Rabbit, Hare, Bunny], [Rabbit, Hare, Bunny]},
+                          [Rabbit, Hare, Bunny]),
+
+    ok = rabbit_ct_broker_helpers:stop_node(Config, Hare),
+    ok = rabbit_ct_broker_helpers:stop_node(Config, Bunny),
+    ok = force_standalone_khepri_boot(Rabbit),
+
+    assert_cluster_status({[Rabbit], [Rabbit], [Rabbit, Hare, Bunny],
+                           [Rabbit, Hare, Bunny], [Rabbit]},
+                          [Rabbit]),
+
+    ok.
+
 %% ----------------------------------------------------------------------------
 %% Internal utils
 %% ----------------------------------------------------------------------------
@@ -1368,6 +1390,9 @@ change_cluster_node_type(Node, Type) ->
 update_cluster_nodes(Node, DiscoveryNode) ->
     rabbit_control_helper:command(update_cluster_nodes, Node, [atom_to_list(DiscoveryNode)]).
 
+force_standalone_khepri_boot(Node) ->
+    rabbit_control_helper:command(force_standalone_khepri_boot, Node, []).
+
 stop_join_start(Node, ClusterTo, Ram) ->
     ok = stop_app(Node),
     ok = join_cluster(Node, ClusterTo, Ram),

deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/force_standalone_khepri_boot.ex

@@ -0,0 +1,45 @@
+## This Source Code Form is subject to the terms of the Mozilla Public
+## License, v. 2.0. If a copy of the MPL was not distributed with this
+## file, You can obtain one at https://mozilla.org/MPL/2.0/.
+##
+## Copyright (c) 2007-2023 VMware, Inc. or its affiliates.  All rights reserved.
+
+defmodule RabbitMQ.CLI.Ctl.Commands.ForceStandaloneKhepriBootCommand do
+  alias RabbitMQ.CLI.Core.{Config, DocGuide}
+
+  @behaviour RabbitMQ.CLI.CommandBehaviour
+
+  use RabbitMQ.CLI.Core.MergesNoDefaults
+  use RabbitMQ.CLI.Core.AcceptsNoPositionalArguments
+
+  def run([], %{node: node_name} = opts) do
+    ret =
+      :rabbit_misc.rpc_call(node_name, :rabbit_khepri, :force_shrink_member_to_current_member, [])
+
+    case ret do
+      {:badrpc, {:EXIT, {:undef, _}}} ->
+        {:error, RabbitMQ.CLI.Core.ExitCodes.exit_usage(),
+         "This command is not supported by node #{node_name}"}
+
+      _ ->
+        ret
+    end
+  end
+
+  use RabbitMQ.CLI.DefaultOutput
+
+  def usage, do: "force_standalone_khepri_boot"
+
+  def usage_doc_guides() do
+    [
+      DocGuide.clustering()
+    ]
+  end
+
+  def help_section(), do: :cluster_management
+
+  def description(),
+    do: "Forces node to start as a standalone node"
+
+  def banner(_, _), do: nil
+end