Struct seekable_async_file::SeekableAsyncFile

pub struct SeekableAsyncFile { /* private fields */ }

A File-like value that can perform async read_at and write_at for I/O at specific offsets without mutating any state (i.e. is thread safe). Metrics are collected, and syncs can be delayed for write batching opportunities as a performance optimisation.

Implementations

impl SeekableAsyncFile

pub async fn open( path: &Path, size: u64, metrics: Arc<SeekableAsyncFileMetrics>, sync_delay: Duration, flags: i32 ) -> Self

Open a file descriptor in read and write modes, creating it if it doesn’t exist. If it already exists, the contents won’t be truncated.

If the mmap feature is being used, to save a stat call, the size must be provided. This also allows opening non-standard files which may have a size of zero (e.g. block devices). A different size value also allows only using a portion of the beginning of the file.

The io_direct and io_dsync parameters set the O_DIRECT and O_DSYNC flags, respectively. Unless you need those flags, provide false.

Make sure to execute start_delayed_data_sync_background_loop in the background after this call.

pub unsafe fn get_mmap_raw_ptr(&self, offset: u64) -> *const u8

pub unsafe fn get_mmap_raw_mut_ptr(&self, offset: u64) -> *mut u8

pub async fn write_at_with_delayed_sync(&self, writes: Vec<WriteRequest>)

pub async fn start_delayed_data_sync_background_loop(&self)

pub async fn sync_data(&self)

Trait Implementations

impl Clone for SeekableAsyncFile

fn clone(&self) -> SeekableAsyncFile

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Off64AsyncRead<'a, Vec<u8, Global>> for SeekableAsyncFile

fn read_at<'life0, 'async_trait>( &'life0 self, offset: u64, len: u64 ) -> Pin<Box<dyn Future<Output = Vec<u8>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

impl Off64AsyncWrite<Vec<u8, Global>> for SeekableAsyncFile

fn write_at<'life0, 'async_trait>( &'life0 self, offset: u64, data: Vec<u8> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

impl<'a> Off64Read<'a, Vec<u8, Global>> for SeekableAsyncFile

fn read_at(&self, offset: u64, len: u64) -> Vec<u8>

impl<'a> Off64Write<Vec<u8, Global>> for SeekableAsyncFile

fn write_at<'v>(&self, offset: u64, data: Vec<u8>)