blob: bc4295be7dc3a087fe7d51fdc19266baf08c5077 [file] [log] [blame]
nn_pipeline(7)
==============
NAME
----
nn_pipeline - scalability protocol for passing tasks through a series of processing steps
SYNOPSIS
--------
*#include <nanomsg/nn.h>*
*#include <nanomsg/pipeline.h>*
DESCRIPTION
-----------
Fair queues messages from the previous processing step and load balances them
among instances of the next processing step.
Socket Types
~~~~~~~~~~~~
NN_PUSH::
This socket is used to send messages to a cluster of load-balanced
nodes. Receive operation is not implemented on this socket type.
NN_PULL::
This socket is used to receive a message from a cluster of nodes. Send
operation is not implemented on this socket type.
Socket Options
~~~~~~~~~~~~~~
No protocol-specific socket options are defined at the moment.
SEE ALSO
--------
<<nn_bus#,nn_bus(7)>>
<<nn_pubsub#,nn_pubsub(7)>>
<<nn_reqrep#,nn_reqrep(7)>>
<<nn_survey#,nn_survey(7)>>
<<nn_pair#,nn_pair(7)>>
<<nanomsg#,nanomsg(7)>>
AUTHORS
-------
link:mailto:sustrik@250bpm.com[Martin Sustrik]