Struct Ring 

pub struct Ring<F: BackendFactory> { /* private fields */ }

Submission and completion router.

Implementations

impl<F: BackendFactory> Ring<F>

pub fn new(config: RingConfig) -> Result<Self>

Creates a ring using the selected backend policy.

pub fn backend_kind(&self) -> BackendKind

Returns the active backend kind.

pub fn queue_depth(&self) -> u32

Returns the configured queue depth.

pub fn batch<I, O>(&self, ops: I) -> Result<Vec<O::Output>>

where I: IntoIterator<Item = O>, O: Op,

Submits a batch of operations and returns ordered results.

The ring keeps at most queue_depth requests in flight at once, so callers can batch arbitrarily large iterators without manually chunking.

pub fn chain<T>( &self, run: impl FnOnce(ChainContext<'_, F>) -> Result<T>, ) -> Result<T>

Runs a dependent chain of operations in one call.

This is the high-level API for flows where later operations require outputs from earlier ones, such as connect -> send -> recv.

pub fn submit<O: Op>(&self, op: O) -> Result<Request<O::Output>>

Submits an operation and returns a typed request handle.

pub fn complete(&self, timeout: Option<Duration>) -> Result<CompletionEvent>

Blocks until one completion is routed.

pub fn cancel(&self, id: u64) -> Result<()>

Attempts to cancel a submitted operation.

pub fn in_flight(&self) -> Result<usize>

Returns the number of tracked in-flight operations.

Trait Implementations

impl<F: Clone + BackendFactory> Clone for Ring<F>

fn clone(&self) -> Ring<F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F: BackendFactory> Drop for Ring<F>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.