Skip to content

Commit 3b4af50

Browse files
authored
Merge pull request rabbitmq#1577 from rabbitmq/rabbitmq-peer-discovery-k8s-23
Make it possible for peer discovery backends to provide their own RSD range
2 parents a267d6b + e840323 commit 3b4af50

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/rabbit_peer_discovery.erl

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -184,11 +184,16 @@ inject_randomized_delay() ->
184184
-spec randomized_delay_range_in_ms() -> {integer(), integer()}.
185185

186186
randomized_delay_range_in_ms() ->
187+
Backend = backend(),
188+
Default = case erlang:function_exported(Backend, randomized_startup_delay_range, 0) of
189+
true -> Backend:randomized_startup_delay_range();
190+
false -> ?DEFAULT_STARTUP_RANDOMIZED_DELAY
191+
end,
187192
{Min, Max} = case application:get_env(rabbit, cluster_formation) of
188193
{ok, Proplist} ->
189-
proplists:get_value(randomized_startup_delay_range, Proplist, ?DEFAULT_STARTUP_RANDOMIZED_DELAY);
194+
proplists:get_value(randomized_startup_delay_range, Proplist, Default);
190195
undefined ->
191-
?DEFAULT_STARTUP_RANDOMIZED_DELAY
196+
Default
192197
end,
193198
{Min * 1000, Max * 1000}.
194199

0 commit comments

Comments
 (0)