NN_PIPELINE

Section: nanomsg 1.1.5 (7)
Updated: 2021-01-26
Page Index
 

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) nn_pubsub(7) nn_reqrep(7) nn_survey(7) nn_pair(7) nanomsg(7)  

AUTHORS


 

Index

NAME
SYNOPSIS
DESCRIPTION
Socket Types
Socket Options
SEE ALSO
AUTHORS