'\" t
.\"     Title: nn_pipeline
.\"    Author: [see the "AUTHOR(S)" section]
.\" Generator: Asciidoctor 2.0.20
.\"      Date: 2024-02-21
.\"    Manual: nanomsg 1.2.1
.\"    Source: \ \&
.\"  Language: English
.\"
.TH "NN_PIPELINE" "7" "2024-02-21" "\ \&" "nanomsg 1.2.1"
.ie \n(.g .ds Aq \(aq
.el       .ds Aq '
.ss \n[.ss] 0
.nh
.ad l
.de URL
\fI\\$2\fP <\\$1>\\$3
..
.als MTO URL
.if \n[.g] \{\
.  mso www.tmac
.  am URL
.    ad l
.  .
.  am MTO
.    ad l
.  .
.  LINKSTYLE blue R < >
.\}
.SH "NAME"
nn_pipeline \- scalability protocol for passing tasks through a series of processing steps
.SH "SYNOPSIS"
.sp
\fB#include <nanomsg/nn.h>\fP
.sp
\fB#include <nanomsg/pipeline.h>\fP
.SH "DESCRIPTION"
.sp
Fair queues messages from the previous processing step and load balances them
among instances of the next processing step.
.SS "Socket Types"
.sp
NN_PUSH
.RS 4
This socket is used to send messages to a cluster of load\-balanced
nodes. Receive operation is not implemented on this socket type.
.RE
.sp
NN_PULL
.RS 4
This socket is used to receive a message from a cluster of nodes. Send
operation is not implemented on this socket type.
.RE
.SS "Socket Options"
.sp
No protocol\-specific socket options are defined at the moment.
.SH "SEE ALSO"
.sp
nn_bus(7)
nn_pubsub(7)
nn_reqrep(7)
nn_survey(7)
nn_pair(7)
nanomsg(7)
.SH "AUTHORS"
.sp
.MTO "sustrik\(at250bpm.com" "Martin Sustrik" ""