| 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.7.txt#,nn_bus(7)>> |
| <<nn_pubsub.7.txt#,nn_pubsub(7)>> |
| <<nn_reqrep.7.txt#,nn_reqrep(7)>> |
| <<nn_survey.7.txt#,nn_survey(7)>> |
| <<nn_pair.7.txt#,nn_pair(7)>> |
| <<nanomsg.7.txt#,nanomsg(7)>> |
| |
| |
| AUTHORS |
| ------- |
| link:mailto:sustrik@250bpm.com[Martin Sustrik] |
| |