Struct PoolClient

pub struct PoolClient(/* private fields */);

A client for manipulating a running IoUringPool.

Implementations

impl PoolClient

pub fn set_idle_task<F>(&self, f: F)

where F: 'static + Send + AsyncFnOnce(IdleControl),

Sets the idle task to run. The task is returned by f, which receives the file descriptor of the IO ring.

The idle task is run before waiting on the IO ring. The idle task can block synchronously by first calling IdleControl::pre_block, and then by polling on the IO ring while the task blocks.

pub fn initiator(&self) -> &IoInitiator

Returns the IO initiator.

pub fn set_iowq_affinity(&self, affinity: &CpuSet) -> Result<()>

Sets the CPU affinity for the kernel io-uring worker threads.

pub fn set_iowq_max_workers( &self, bounded: Option<u32>, unbounded: Option<u32>, ) -> Result<()>

Sets the maximum bounded and unbounded workers (per NUMA node) for the ring.

Trait Implementations

impl Clone for PoolClient

fn clone(&self) -> PoolClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PoolClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Inspect for PoolClient

fn inspect(&self, req: Request<'_>)

Inspects the object.

impl Schedule for PoolClient

fn schedule(&self, runnable: Runnable)

Schedules a task to run.

fn name(&self) -> Arc<str>

Gets the executor name.