Skip to content

Commit 7706c4e

Browse files
committed
rabbit_khepri: Use rabbit_db_cluster's members/2 and nodes/2
`locally_known_members/1` and `locally_known_node/1` were replaced with `members/2` and `nodes/2` with `favor` set to `low_latency` - this matches the interface for queries in Khepri.
1 parent b318c94 commit 7706c4e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -653,7 +653,7 @@ members() ->
653653
%% The returned list is empty if there was an error.
654654

655655
locally_known_members() ->
656-
case khepri_cluster:locally_known_members(?RA_CLUSTER_NAME) of
656+
case khepri_cluster:members(?RA_CLUSTER_NAME, #{favor => low_latency}) of
657657
{ok, Members} -> Members;
658658
{error, _Reason} -> []
659659
end.
@@ -683,7 +683,7 @@ nodes() ->
683683
%% The returned list is empty if there was an error.
684684

685685
locally_known_nodes() ->
686-
case khepri_cluster:locally_known_nodes(?RA_CLUSTER_NAME) of
686+
case khepri_cluster:nodes(?RA_CLUSTER_NAME, #{favor => low_latency}) of
687687
{ok, Nodes} -> Nodes;
688688
{error, _Reason} -> []
689689
end.

0 commit comments

Comments
 (0)