Expand description
io_uring-based response stage — routes matching output to connections via
IORING_OP_SEND.
Replaces the blocking write(2) + BufWriter flush path with batched
io_uring sends. Instead of N write(2) syscalls (one per dirty connection
on flush), we submit N SEND SQEs in a single io_uring_enter call.
Same SPSC consumption and journal cursor gating as response.rs.
Runs on a dedicated OS thread.
Re-exports§
pub use crate::ControlEvent;
Structs§
- Response
- Configuration and shared state for the response stage.
Functions§
- run
- Run the io_uring response stage loop. Blocks the calling thread until shutdown.
Type Aliases§
- Response
Encoder Arc - Encoder type alias: response encoder bound to the application’s
Report/QueryResponsetypes. Hides the longdyn ResponseEncoder<Report = ..., Query = ...>at call sites.