Behaviours: supervisor.
add_fitting/4 | Start a new fitting under this supervisor. |
init/1 | Initialize this supervisor. |
start_link/0 | Start the supervisor. |
terminate_fitting/1 | Terminate a fitting immediately. |
add_fitting(Builder::pid(), Spec::riak_pipe:fitting_spec(), Output::riak_pipe:fitting(), Options::riak_pipe:exec_opts()) -> {ok, pid(), riak_pipe:fitting()}
Start a new fitting under this supervisor.
init(X1::[]) -> {ok, {{supervisor:strategy(), pos_integer(), pos_integer()}, [supervisor:child_spec()]}}
Initialize this supervisor. This is a simple_one_for_one
,
whose child spec is for starting riak_pipe_fitting
FSMs.
start_link() -> {ok, pid()} | ignore | {error, term()}
Start the supervisor. It will be registered under the atom
riak_pipe_fitting_sup
.
terminate_fitting(Fitting::riak_pipe:fitting()) -> ok | {error, term()}
Terminate a fitting immediately. Useful for tearing down pipelines that may be otherwise swamped with messages from restarting workers.
Generated by EDoc, Sep 17 2012, 17:05:43.