Skip to content

Commit 9b5ab14

Browse files
the-mikedavisdumbbell
authored andcommitted
Khepri: Adapt to new khepri_cluster:members/2 API
[Why] In Khepri 0.17.0, `khepri_cluster:locally_known_members/1` and `khepri_cluster:locally_known_node/1` were replaced with `khepri_cluster:members/2` and `khepri_cluster:nodes/2` with `favor` set to `low_latency` - this matches the interface for queries in Khepri.
1 parent cbe271e commit 9b5ab14

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

622622
locally_known_members() ->
623-
case khepri_cluster:locally_known_members(?RA_CLUSTER_NAME) of
623+
case khepri_cluster:members(?RA_CLUSTER_NAME, #{favor => low_latency}) of
624624
{ok, Members} -> Members;
625625
{error, _Reason} -> []
626626
end.
@@ -650,7 +650,7 @@ nodes() ->
650650
%% The returned list is empty if there was an error.
651651

652652
locally_known_nodes() ->
653-
case khepri_cluster:locally_known_nodes(?RA_CLUSTER_NAME) of
653+
case khepri_cluster:nodes(?RA_CLUSTER_NAME, #{favor => low_latency}) of
654654
{ok, Nodes} -> Nodes;
655655
{error, _Reason} -> []
656656
end.

0 commit comments

Comments
 (0)