Methods for sending messages to the sink.
Sink messages are delivered as three record types:#pipe_result{}
, #pipe_log{}
, and #pipe_eoi{}
.
eoi/1 | Send an end-of-inputs message to the sink (used by fittings). |
log/3 | Send a log message to the sink (used by worker processes and fittings). |
result/3 | Send a result to the sink (used by worker processes). |
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(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(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, Jun 3 2013, 09:00:34.