rzmq 0.5.25

High performance, CPU and memory efficient, fully asynchronous, safe pure-Rust implementation of ZeroMQ (ØMQ) messaging with io_uring and TCP Cork acceleration on Linux.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

pub(crate) mod actor;
pub(crate) mod egress_buffer;
pub(crate) mod egress_driver;
pub(crate) mod message_processor;
#[cfg(target_os = "linux")]
pub(crate) mod cork;
pub(crate) mod iface;
pub(crate) mod pipe_manager;
pub(crate) mod regulator;
pub(crate) mod states;
pub(crate) mod types;

pub(crate) use iface::ScaConnectionIface;

/// Per-read iteration chunk size for the synchronous greedy drain stack buffer.
/// Must be a compile-time constant because it sizes a stack array.
#[cfg(target_os = "macos")]
pub(crate) const INGRESS_GREEDY_CHUNK: usize = 65536;
#[cfg(not(target_os = "macos"))]
pub(crate) const INGRESS_GREEDY_CHUNK: usize = 65536 * 8;