1NN_PIPELINE(7)                   nanomsg 1.1.5                  NN_PIPELINE(7)
2
3
4

NAME

6       nn_pipeline - scalability protocol for passing tasks through a series
7       of processing steps
8

SYNOPSIS

10       #include <nanomsg/nn.h>
11
12       #include <nanomsg/pipeline.h>
13

DESCRIPTION

15       Fair queues messages from the previous processing step and load
16       balances them among instances of the next processing step.
17
18   Socket Types
19       NN_PUSH
20           This socket is used to send messages to a cluster of load-balanced
21           nodes. Receive operation is not implemented on this socket type.
22
23       NN_PULL
24           This socket is used to receive a message from a cluster of nodes.
25           Send operation is not implemented on this socket type.
26
27   Socket Options
28       No protocol-specific socket options are defined at the moment.
29

SEE ALSO

31       nn_bus(7) nn_pubsub(7) nn_reqrep(7) nn_survey(7) nn_pair(7) nanomsg(7)
32

AUTHORS

34       Martin Sustrik <sustrik@250bpm.com>
35
36
37
38                                  2022-01-20                    NN_PIPELINE(7)