Module riak_pipe_w_tee

Send inputs to another fitting (often the sink) in addition to the output.

Behaviours: riak_pipe_vnode_worker.

Description

Send inputs to another fitting (often the sink) in addition to the output.

If the argument to this fitting is the atom sink, every input will be sent to the sink. If the argument is a #fitting{} record, every input will be sent to that fitting.

Data Types

state()

abstract datatype: state()

Function Index

done/1Unused.
init/2Init just stashes the Partition and FittingDetails for later.
process/3Processing an input involves sending it to both the fitting specified by the argument (possibly the sink), and to the output.
validate_arg/1Check that the fitting's argument is either the atom sink or a #fitting{} record.

Function Details

done/1

done(State::state()) -> ok

Unused.

init/2

init(Partition::riak_pipe_vnode:partition(), FittingDetails::riak_pipe_fitting:details()) -> {ok, state()}

Init just stashes the Partition and FittingDetails for later.

process/3

process(Input::term(), Last::boolean(), State::state()) -> {ok, state()}

Processing an input involves sending it to both the fitting specified by the argument (possibly the sink), and to the output.

validate_arg/1

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, Oct 20 2012, 17:51:48.