Skip to content

Commit d1268e7

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 2820495 commit d1268e7

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
@@ -635,7 +635,7 @@ members() ->
635635
%% The returned list is empty if there was an error.
636636

637637
locally_known_members() ->
638-
case khepri_cluster:locally_known_members(?RA_CLUSTER_NAME) of
638+
case khepri_cluster:members(?RA_CLUSTER_NAME, #{favor => low_latency}) of
639639
{ok, Members} -> Members;
640640
{error, _Reason} -> []
641641
end.
@@ -665,7 +665,7 @@ nodes() ->
665665
%% The returned list is empty if there was an error.
666666

667667
locally_known_nodes() ->
668-
case khepri_cluster:locally_known_nodes(?RA_CLUSTER_NAME) of
668+
case khepri_cluster:nodes(?RA_CLUSTER_NAME, #{favor => low_latency}) of
669669
{ok, Nodes} -> Nodes;
670670
{error, _Reason} -> []
671671
end.

0 commit comments

Comments
 (0)