Skip to content

Commit bd3aee3

Browse files
committed
Khepri: Clean up the setup/clustering code of the integration code
[Why] The `rabbit_khepri` module grew during the work to add Khepri support to RabbitMQ and while Khepri was itself written. The current code is therefore unorganized. [How] This commit tries to sort the code that manages the setup of Khepri and the functions tha deal with the Khepri cluster. It also groups functions which provide support for CLI commands. It also adds documentation to several functions. Finally, when a node joins a cluster, we stop displaying the content of the Khepri tree.
1 parent d2b5f51 commit bd3aee3

File tree

2 files changed

+439
-248
lines changed

2 files changed

+439
-248
lines changed

deps/rabbit/src/rabbit_db_cluster.erl

+1-1
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ forget_member_using_khepri(_Node, true) ->
279279
#{domain => ?RMQLOG_DOMAIN_DB}),
280280
{error, not_supported};
281281
forget_member_using_khepri(Node, false = _RemoveWhenOffline) ->
282-
rabbit_khepri:leave_cluster(Node).
282+
rabbit_khepri:remove_member(Node).
283283

284284
%% -------------------------------------------------------------------
285285
%% Cluster update.

0 commit comments

Comments
 (0)