Behaviours: riak_pipe_vnode_worker.
Input
:: term()
Partition
:: riak_pipe_vnode:partition()
FittingDetails
:: #fitting_details{}
Partition
and FittingDetails
along
with riak_pipe_vnode_worker:send_output/3
to send
whatever outputs it likes (this allows the fitting to be used
as "filter" as well as "map").
abstract datatype: state()
done/1 | Unused. |
init/2 | Init just stashes the Partition and FittingDetails for later. |
process/3 | Process evaluates the fitting's argument function. |
validate_arg/1 | Check that the argument is a valid function of arity 3. |
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.
Process evaluates the fitting's argument function.
validate_arg(Fun::term()) -> ok | {error, iolist()}
Check that the argument is a valid function of arity 3. See
riak_pipe_v_validate_function/3
.
Generated by EDoc, Jul 26 2012, 21:16:11.