Packages

steamroller

0.12.0
0.14.3 0.14.2 0.14.1 0.14.0 0.13.2 0.13.1 0.13.0 0.12.2 0.12.1 0.12.0 0.11.6 0.11.5 0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.2 0.10.1 0.10.0 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0 0.8.0 0.7.0 0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.0

An opinionated Erlang code formatter.

HexDocs

Current section

Files

Jump to
Readme
37 Versions
1 Dependency
Dependants
Files
Activity
steamroller src steamroller_worker_sup.erl
Raw

src/steamroller_worker_sup.erl 

-module(steamroller_worker_sup).



-behaviour(supervisor).



-export([start_link/1, init/1, terminate_children/0]).



-define(DEFAULT_NUM_WORKERS, 4).



%% API



start_link(Opts) -> supervisor:start_link({local, ?MODULE}, ?MODULE, Opts).



init(Opts) ->

  NumWorkers = proplists:get_value(j, Opts, ?DEFAULT_NUM_WORKERS),

  RestartStrategy = #{strategy => one_for_one, intensity => 5, period => 60},

  Children = [child(Id) || Id <- lists:seq(1, NumWorkers)],

  {ok, {RestartStrategy, Children}}.



terminate_children() ->

  CountChildren = supervisor:count_children(?MODULE),

  NumWorkers = proplists:get_value(workers, CountChildren),

  [supervisor:terminate_child(?MODULE, id(Id)) || Id <- lists:seq(1, NumWorkers)].



%% Internal



child(Id) -> #{id => id(Id), start => {steamroller_worker, start_link, [Id]}}.



id(Id) -> list_to_atom("steamroller_worker_" ++ integer_to_list(Id)).