1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
%% This Source Code Form is subject to the terms of the Mozilla Public
%% License, v. 2.0. If a copy of the MPL was not distributed with this
%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
%%
%% Copyright (c) 2007-2020 VMware, Inc. or its affiliates. All rights reserved.
%%
-module(rabbit_peer_discovery_classic_config).
-behaviour(rabbit_peer_discovery_backend).
-include("rabbit.hrl").
-export([list_nodes/0, supports_registration/0, register/0, unregister/0,
post_registration/0, lock/1, unlock/1]).
%%
%% API
%%
-spec list_nodes() -> {ok, {Nodes :: [node()], rabbit_types:node_type()}} |
{error, Reason :: string()}.
list_nodes() ->
case application:get_env(rabbit, cluster_nodes, {[], disc}) of
{_Nodes, _NodeType} = Pair -> {ok, Pair};
Nodes when is_list(Nodes) -> {ok, {Nodes, disc}}
end.
-spec supports_registration() -> boolean().
supports_registration() ->
%% If we don't have any nodes configured, skip randomized delay and similar operations
%% as we don't want to delay startup for no reason. MK.
has_any_peer_nodes_configured().
-spec register() -> ok.
register() ->
ok.
-spec unregister() -> ok.
unregister() ->
ok.
-spec post_registration() -> ok.
post_registration() ->
ok.
-spec lock(Node :: atom()) -> not_supported.
lock(_Node) ->
not_supported.
-spec unlock(Data :: term()) -> ok.
unlock(_Data) ->
ok.
%%
%% Helpers
%%
has_any_peer_nodes_configured() ->
case application:get_env(rabbit, cluster_nodes, []) of
{[], _NodeType} ->
false;
{Nodes, _NodeType} when is_list(Nodes) ->
true;
[] ->
false;
Nodes when is_list(Nodes) ->
true
end.
|
