Add src/hk_search_job_sup.erl

src/hk_search_job_sup.erl

@@ -0,0 +1,37 @@
+%%%-------------------------------------------------------------------
+%%% @doc HK-SEARCH :: supervises one `hk_search_job' per active or
+%%% recently-completed search job.
+%%%
+%%% `temporary', `simple_one_for_one': a search job is a one-shot
+%%% pipeline run, not a long-lived resource like a browser session.
+%%% It is never restarted by the supervisor -- a failed pipeline
+%%% stage transitions the job's own state machine to `failed'
+%%% (see `hk_search_job:fail/2') rather than crashing the process,
+%%% so there is normally nothing for the supervisor to recover from;
+%%% `temporary' just means an unexpected crash doesn't loop.
+%%% @end
+%%%-------------------------------------------------------------------
+-module(hk_search_job_sup).
+-behaviour(supervisor).
+
+-export([start_link/0, init/1, start_job/1]).
+
+start_link() ->
+    hk_sup_util:start_link_retry(
+        fun() -> supervisor:start_link({local, ?MODULE}, ?MODULE, []) end).
+
+-spec start_job(map()) -> {ok, pid()} | {error, term()}.
+start_job(Args) ->
+    supervisor:start_child(?MODULE, [Args]).
+
+init([]) ->
+    SupFlags = #{strategy => simple_one_for_one, intensity => 20, period => 60},
+    Children = [
+        #{id => hk_search_job,
+          start => {hk_search_job, start_link, []},
+          restart => temporary,
+          shutdown => 5000,
+          type => worker,
+          modules => [hk_search_job]}
+    ],
+    {ok, {SupFlags, Children}}.