nn_pipeline - Man Page
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) nn_pubsub(7) nn_reqrep(7) nn_survey(7) nn_pair(7) nanomsg(7)
Authors
Referenced By
nanomsg(7), nn_bus(7), nn_pair(7), nn_pubsub(7), nn_reqrep(7), nn_socket(3), nn_survey(7).
2024-01-25 nanomsg 1.1.5