Trait VortexReadAt

pub trait VortexReadAt: 'static {
    // Required methods
    fn read_byte_range(
        &self,
        range: Range<u64>,
        alignment: Alignment,
    ) -> impl Future<Output = Result<ByteBuffer>>;
    fn size(&self) -> impl Future<Output = Result<u64>>;

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

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, range: Range<u64>, alignment: Alignment, ) -> impl Future<Output = Result<ByteBuffer>>

Request an asynchronous positional read. Results will be returned as a ByteBuffer.

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

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) -> PerformanceHint

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl VortexReadAt for ByteBuffer

async fn read_byte_range( &self, range: Range<u64>, alignment: Alignment, ) -> Result<ByteBuffer>

fn performance_hint(&self) -> PerformanceHint

async fn size(&self) -> Result<u64>

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

async fn read_byte_range( &self, range: Range<u64>, alignment: Alignment, ) -> Result<ByteBuffer>

fn performance_hint(&self) -> PerformanceHint

async fn size(&self) -> Result<u64>

Implementors

impl<T: VortexReadAt> VortexReadAt for InstrumentedReadAt<T>