Module riak_pipe_w_crash

It's what we do: crash.

Behaviours: riak_pipe_vnode_worker.

Description

It's what we do: crash.

Data Types

state()

abstract datatype: state()

Function Index

done/1Unused.
init/2Initialization just stows the partition and fitting details in the module's state, for sending outputs in process/3.
process/3Process just sends Input directly to the next fitting.

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 partition and fitting details in the module's state, for sending outputs in process/3.

process/3

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

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, Apr 3 2013, 21:58:01.