Module riak_pipe_w_pass

Simple pass-thru fitting.

Behaviours: riak_pipe_vnode_worker.

Description

Simple pass-thru fitting. Just passes its input directly to its output. This fitting should work with any consistent-hash function. It ignores its argument, and requires no archiving for handoff.

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, Nov 21 2012, 15:51:29.