Behaviours: riak_pipe_vnode_worker.
Send inputs to another fitting (often the sink) in addition to the output.
If the argument to this fitting is the atomsink
, every
input will be sent to the sink. If the argument is a
#fitting{}
record, every input will be sent to that fitting.
abstract datatype: state()
done/1 | Unused. |
init/2 | Init just stashes the Partition and FittingDetails for later. |
process/3 | Processing an input involves sending it to both the fitting specified by the argument (possibly the sink), and to the output. |
validate_arg/1 | Check that the fitting's argument is either the atom sink or
a #fitting{} record. |
done(State::state()) -> ok
Unused.
init(Partition::riak_pipe_vnode:partition(), FittingDetails::riak_pipe_fitting:details()) -> {ok, state()}
Init just stashes the Partition
and FittingDetails
for later.
Processing an input involves sending it to both the fitting specified by the argument (possibly the sink), and to the output.
validate_arg(Fitting::term()) -> ok | {error, iolist()}
Check that the fitting's argument is either the atom sink
or
a #fitting{}
record.
Generated by EDoc, Jul 26 2012, 21:16:10.