Behaviours: riak_pipe_vnode_worker.
abstract datatype: state()
done/1 | Unused. |
init/2 | Initialization just stows the partition and fitting details in
the module's state, for sending outputs in process/3 . |
process/3 | Process just sends Input directly to the next fitting. |
done(State::state()) -> ok
Unused.
init(Partition::riak_pipe_vnode:partition(), FittingDetails::riak_pipe_fitting:details()) -> {ok, state()}
Initialization just stows the partition and fitting details in
the module's state, for sending outputs in process/3
.
Process just sends Input
directly to the next fitting. This
function also generates two trace messages: {processing,
Input}
before sending the output, and {processed, Input}
after
the blocking output send has returned. This can be useful for
dropping in another pipeline to watching data move through it.
Generated by EDoc, Aug 5 2012, 06:58:52.