Module riak_pipe_sink

Methods for sending messages to the sink.

Description

Methods for sending messages to the sink.

Sink messages are delivered as three record types: #pipe_result{}, #pipe_log{}, and #pipe_eoi{}.

Function Index

eoi/1Send an end-of-inputs message to the sink (used by fittings).
log/3Send a log message to the sink (used by worker processes and fittings).
result/3Send a result to the sink (used by worker processes).

Function Details

eoi/1

eoi(Sink::riak_pipe:fitting()) -> #pipe_eoi{}

Send an end-of-inputs message to the sink (used by fittings). The message is delivered as a #pipe_eoi{} record in the sink process's mailbox.

log/3

log(From::term(), Sink::riak_pipe:fitting(), Msg::term()) -> #pipe_log{}

Send a log message to the sink (used by worker processes and fittings). The message is delivered as a #pipe_log{} record in the sink process's mailbox.

result/3

result(From::term(), Sink::riak_pipe:fitting(), Output::term()) -> #pipe_result{}

Send a result to the sink (used by worker processes). The result is delivered as a #pipe_result{} record in the sink process's mailbox.


Generated by EDoc, Nov 19 2012, 04:53:19.