summaryrefslogtreecommitdiff
path: root/merge/src/merge_fetch_newentries_sup.erl
diff options
context:
space:
mode:
authorLinus Nordberg <linus@nordu.net>2017-07-06 18:15:08 +0200
committerLinus Nordberg <linus@nordu.net>2017-07-06 18:15:08 +0200
commit489df8ecaf16ca7429eb15b31ffbe6f686f5b0d1 (patch)
tree0bf75621b35d7cecd06f4c12d054e9f9ec47f7a6 /merge/src/merge_fetch_newentries_sup.erl
parent05235680257a54f112c44c7854b3afe8300acd40 (diff)
Diffstat (limited to 'merge/src/merge_fetch_newentries_sup.erl')
-rw-r--r--merge/src/merge_fetch_newentries_sup.erl30
1 files changed, 30 insertions, 0 deletions
diff --git a/merge/src/merge_fetch_newentries_sup.erl b/merge/src/merge_fetch_newentries_sup.erl
new file mode 100644
index 0000000..bd33e60
--- /dev/null
+++ b/merge/src/merge_fetch_newentries_sup.erl
@@ -0,0 +1,30 @@
+%%% Copyright (c) 2017, NORDUnet A/S.
+%%% See LICENSE for licensing information.
+
+-module(merge_fetch_newentries_sup).
+-behaviour(supervisor).
+
+-export([start_link/1, init/1]).
+
+start_link(Nodes) ->
+ {ok, Pid} =
+ supervisor:start_link({local, ?MODULE}, ?MODULE, []),
+ Children =
+ lists:map(fun({NodeName, NodeAddress}) ->
+ lager:info("starting newentry worker: ~p", [NodeName]),
+
+ {ok, Child} = supervisor:start_child(
+ ?MODULE,
+ [{NodeName, NodeAddress, 3000}]),
+ Child
+ end, Nodes),
+ lager:debug("~p started newentry workers: ~p", [Pid, Children]),
+ {ok, Pid}.
+
+init([]) ->
+ {ok,
+ {{simple_one_for_one, 3, 10},
+ [{ignored,
+ {merge_fetch_newentries, start_link, []},
+ permanent, 10000, worker,
+ [merge_fetch_newentries]}]}}.