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

Martin Sustrik

Referenced By

nanomsg(7), nn_bus(7), nn_pair(7), nn_pubsub(7), nn_reqrep(7), nn_socket(3), nn_survey(7).

2024-09-04 nanomsg 1.2.1