Skip to main content

Module response

Module response 

Source
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§

ResponseEncoderArc
Encoder type alias: response encoder bound to the application’s Report / QueryResponse types. Hides the long dyn ResponseEncoder<Report = ..., Query = ...> at call sites.