![]() |
![]()
| ![]() |
![]()
NAMEnn_pipeline - scalability protocol for passing tasks through a series of processing steps SYNOPSIS#include <nanomsg/nn.h> #include <nanomsg/pipeline.h> DESCRIPTIONFair queues messages from the previous processing step and load balances them among instances of the next processing step. Socket TypesNN_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 OptionsNo protocol-specific socket options are defined at the moment. SEE ALSOnn_bus(7) nn_pubsub(7) nn_reqrep(7) nn_survey(7) nn_pair(7) nanomsg(7) AUTHORSMartin Sustrik <sustrik@250bpm.com>
|