Struct UringReader 

pub struct UringReader { /* private fields */ }

io_uring-based reader for local files.

This reader uses a dedicated process-wide thread running an io_uring event loop for high-performance asynchronous I/O.

Trait Implementations

impl Debug for UringReader

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

Formats the value using the given formatter.

impl DeepSizeOf for UringReader

fn deep_size_of_children(&self, context: &mut Context) -> usize

Returns an estimation of the heap-managed storage of this object. This does not include the size of the object itself.

fn deep_size_of(&self) -> usize

Returns an estimation of a total size of memory owned by the object, including heap-managed storage.

impl Reader for UringReader

fn size(&self) -> BoxFuture<'_, Result<usize>>

Returns the file size.

fn get_range(&self, range: Range<usize>) -> BoxFuture<'static, Result<Bytes>>

Read a range of bytes using io_uring.

fn get_all(&self) -> BoxFuture<'static, Result<Bytes>>

Read the entire file using io_uring.

fn path(&self) -> &Path

fn block_size(&self) -> usize

Suggest optimal I/O size per storage device.

fn io_parallelism(&self) -> usize

Suggest optimal I/O parallelism per storage device.

fn get_stream(&self) -> BoxFuture<'_, Result<ByteStream>>

Read the entire object as a byte stream.

fn get_range_stream( &self, range: Range<usize>, ) -> BoxFuture<'_, Result<ByteStream>>

Read a byte range as a byte stream.