Module riak_pipe_w_fwd

This worker always returns 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.

Description

This worker always returns 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.

Data Types

state()

abstract datatype: state()

Function Index

done/1Unused.
init/2Initialization just stows the fitting details in the module's state, for sending traces in process/3.
process/3Process just requests that Input be forwarded to the next vnode in its preflist.

Function Details

done/1

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

Unused.

init/2

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/3

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

Process just requests that Input be forwarded to the next vnode in its preflist.


Generated by EDoc, Jun 3 2013, 09:00:33.