Skip to content

Commit d8abd3a

Browse files
committed
Bump Khepri from 0.10.0 to 0.11.0
Release notes: https://github.com/rabbitmq/khepri/releases/tag/v0.11.0
1 parent 9675339 commit d8abd3a

File tree

3 files changed

+27
-7
lines changed

3 files changed

+27
-7
lines changed

MODULE.bazel

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -295,8 +295,8 @@ erlang_package.hex_package(
295295
erlang_package.hex_package(
296296
name = "khepri",
297297
build_file = "@rabbitmq-server//bazel:BUILD.khepri",
298-
sha256 = "da618ec76abd188620c8fbdc16cb8eb94b09055a657c488da7fab160d49abcbe",
299-
version = "0.10.1",
298+
sha256 = "0f90ad4d163493abf8bc03ab161a8c65795fe5578fe16a5a1d27846185e68aaf",
299+
version = "0.11.0",
300300
)
301301

302302
erlang_package.git_package(

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 24 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -524,9 +524,14 @@ ensure_ra_system_started() ->
524524
%% cluster.
525525
%%
526526
%% The membership is as it is known to the Ra leader in the cluster.
527+
%%
528+
%% The returned list is empty if there was an error.
527529

528530
members() ->
529-
khepri_cluster:members(?RA_CLUSTER_NAME).
531+
case khepri_cluster:members(?RA_CLUSTER_NAME) of
532+
{ok, Members} -> Members;
533+
{error, _Reason} -> []
534+
end.
530535

531536
-spec locally_known_members() -> Members when
532537
Members :: [ra:server_id()].
@@ -536,18 +541,28 @@ members() ->
536541
%% The membership is as it is known to the local Ra server and may be
537542
%% inconsistent compared to the "official" membership as seen by the Ra
538543
%% leader.
544+
%%
545+
%% The returned list is empty if there was an error.
539546

540547
locally_known_members() ->
541-
khepri_cluster:locally_known_members(?RA_CLUSTER_NAME).
548+
case khepri_cluster:locally_known_members(?RA_CLUSTER_NAME) of
549+
{ok, Members} -> Members;
550+
{error, _Reason} -> []
551+
end.
542552

543553
-spec nodes() -> Nodes when
544554
Nodes :: [node()].
545555
%% @doc Returns the list of Erlang nodes that are part of the cluster.
546556
%%
547557
%% The membership is as it is known to the Ra leader in the cluster.
558+
%%
559+
%% The returned list is empty if there was an error.
548560

549561
nodes() ->
550-
khepri_cluster:nodes(?RA_CLUSTER_NAME).
562+
case khepri_cluster:nodes(?RA_CLUSTER_NAME) of
563+
{ok, Nodes} -> Nodes;
564+
{error, _Reason} -> []
565+
end.
551566

552567
-spec locally_known_nodes() -> Nodes when
553568
Nodes :: [node()].
@@ -556,9 +571,14 @@ nodes() ->
556571
%% The membership is as it is known to the local Ra server and may be
557572
%% inconsistent compared to the "official" membership as seen by the Ra
558573
%% leader.
574+
%%
575+
%% The returned list is empty if there was an error.
559576

560577
locally_known_nodes() ->
561-
khepri_cluster:locally_known_nodes(?RA_CLUSTER_NAME).
578+
case khepri_cluster:locally_known_nodes(?RA_CLUSTER_NAME) of
579+
{ok, Nodes} -> Nodes;
580+
{error, _Reason} -> []
581+
end.
562582

563583
-spec get_ra_cluster_name() -> RaClusterName when
564584
RaClusterName :: ra:cluster_name().

rabbitmq-components.mk

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ dep_accept = hex 0.3.5
115115
dep_cowboy = hex 2.11.0
116116
dep_cowlib = hex 2.12.1
117117
dep_credentials_obfuscation = hex 3.4.0
118-
dep_khepri = hex 0.10.0
118+
dep_khepri = hex 0.11.0
119119
dep_khepri_mnesia_migration = hex 0.2.1
120120
dep_looking_glass = git https://github.com/rabbitmq/looking_glass.git main
121121
dep_prometheus = hex 4.11.0

0 commit comments

Comments
 (0)