rzmq 0.5.11

High performance, 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
#![cfg(feature = "io-uring")]

use crate::ZmqError; // Common error type from the crate root

pub mod buffer_manager;
pub mod connection_handler;
pub mod ops;
pub mod send_buffer_pool;
pub mod signaling_op_sender;
pub mod worker;
pub mod zmtp_handler;

// Re-export key types for easier access from the ZMTP engine adapter that will use this backend
pub use connection_handler::{ProtocolHandlerFactory, WorkerIoConfig};
pub use ops::{UringOpCompletion, UringOpRequest, UserData}; // For registering protocol handlers

// Helper type for results within this backend
pub(crate) type UringBackendResult<T> = Result<T, ZmqError>;