Trait vortex_io::VortexReadAt

pub trait VortexReadAt:
    Send
    + Sync
    + Clone
    + 'static {
    // Required methods
    fn read_byte_range(
        &self,
        pos: u64,
        len: u64,
    ) -> impl Future<Output = Result<Buffer>> + 'static;
    fn size(&self) -> impl Future<Output = Result<u64>> + 'static;

    // Provided method
    fn performance_hint(&self) -> usize { ... }
}

A trait for types that support asynchronous reads.

References to the type must be safe to share across threads, but spawned futures may be !Send to support thread-per-core implementations.

Readers must be cheaply cloneable to allow for easy sharing across tasks or threads.

Required Methods

fn read_byte_range( &self, pos: u64, len: u64, ) -> impl Future<Output = Result<Buffer>> + 'static

Request an asynchronous positional read. Results will be returned as a [Buffer].

If the reader does not have the requested number of bytes, the returned Future will complete with an UnexpectedEof.

Thread Safety

The resultant Future need not be Send, allowing implementations that use thread-per-core executors.

fn size(&self) -> impl Future<Output = Result<u64>> + 'static

Asynchronously get the number of bytes of data readable.

For a file it will be the size in bytes, for an object in an ObjectStore it will be the ObjectMeta::size.

Provided Methods

fn performance_hint(&self) -> usize

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl VortexReadAt for Buffer

fn read_byte_range( &self, pos: u64, len: u64, ) -> impl Future<Output = Result<Buffer>> + 'static

fn size(&self) -> impl Future<Output = Result<u64>> + 'static

impl VortexReadAt for File

fn read_byte_range( &self, pos: u64, len: u64, ) -> impl Future<Output = Result<Buffer>> + 'static

fn size(&self) -> impl Future<Output = Result<u64>> + 'static

impl<T: VortexReadAt> VortexReadAt for Arc<T>

fn read_byte_range( &self, pos: u64, len: u64, ) -> impl Future<Output = Result<Buffer>> + 'static

fn performance_hint(&self) -> usize

fn size(&self) -> impl Future<Output = Result<u64>> + 'static

Implementors

impl VortexReadAt for ObjectStoreReadAt

impl VortexReadAt for TokioFile

impl<R: VortexReadAt> VortexReadAt for OffsetReadAt<R>