wipmergefetch

1 files changed, 29 insertions, 0 deletions

diff --git a/merge/src/merge_fetch_sup.erl b/merge/src/merge_fetch_sup.erl
new file mode 100644
index 0000000..6dd1735
--- /dev/null
+++ b/merge/src/merge_fetch_sup.erl
@@ -0,0 +1,29 @@
+%%% Copyright (c) 2017, NORDUnet A/S.
+%%% See LICENSE for licensing information.
+
+-module(merge_fetch_sup).
+-behaviour(supervisor).
+
+-export([start_link/1, init/1]).
+
+start_link(Args) ->
+    supervisor:start_link({local, ?MODULE}, ?MODULE, Args).
+
+init(StorageNodes) ->
+    lager:debug("starting with storage nodes: ~p", [StorageNodes]),
+    {ok,
+     {{one_for_all, 3, 10},
+      [
+       {merge_fetch_newentries_sup,
+        {merge_fetch_newentries_sup, start_link, [StorageNodes]},
+        transient, infinity, supervisor,
+        [merge_fetch_newentries_sup]},
+       {merge_fetch_ctrl,
+        {merge_fetch_ctrl, start_link, [StorageNodes]},
+        permanent, 10000, worker,
+        [merge_fetch_ctrl]},
+       {merge_fetch_fetch_sup,
+        {merge_fetch_fetch_sup, start_link, [StorageNodes]},
+        transient, infinity, supervisor,
+        [merge_fetch_fetch_sup]}
+      ]}}.