forward_preflist
for each input,
in order to get the worker to send the input on to the next
vnode in the preflist.
Behaviours: riak_pipe_vnode_worker.
forward_preflist
for each input,
in order to get the worker to send the input on to the next
vnode in the preflist. It is used by the vnode to disperse
enqueued inputs for a worker, if the worker fails, and then
also fails to restart.
abstract datatype: state()
done/1 | Unused. |
init/2 | Initialization just stows the fitting details in the module's
state, for sending traces in process/3 . |
process/3 | Process just requests that Input be forwarded to the next
vnode in its preflist. |
done(State::state()) -> ok
Unused.
init(Partition::riak_pipe_vnode:partition(), FittingDetails::riak_pipe_fitting:details()) -> {ok, state()}
Initialization just stows the fitting details in the module's
state, for sending traces in process/3
.
Process just requests that Input
be forwarded to the next
vnode in its preflist.
Generated by EDoc, Aug 5 2012, 06:59:09.