We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b704d8d commit 06ed5a7Copy full SHA for 06ed5a7
deps/rabbit/src/rabbit_khepri.erl
@@ -86,6 +86,8 @@
86
-export([if_has_data/1,
87
if_has_data_wildcard/0]).
88
89
+-export([force_shrink_member_to_current_member/0]).
90
+
91
-ifdef(TEST).
92
-export([force_metadata_store/1,
93
clear_forced_metadata_store/0]).
@@ -372,6 +374,10 @@ force_reset() ->
372
374
DataDir = maps:get(data_dir, ra_system:fetch(coordination)),
373
375
ok = rabbit_file:recursive_delete(filelib:wildcard(DataDir ++ "/*")).
376
377
+force_shrink_member_to_current_member() ->
378
+ ok = ra_server_proc:force_shrink_members_to_current_member(
379
+ {?RA_CLUSTER_NAME, node()}).
380
381
ensure_ra_system_started() ->
382
{ok, _} = application:ensure_all_started(khepri),
383
ok = rabbit_ra_systems:ensure_ra_system_started(?RA_SYSTEM).
0 commit comments