Struct growthring::WALFileAIO

pub struct WALFileAIO { /* private fields */ }

Implementations

impl WALFileAIO

pub fn new( rootfd: BorrowedFd<'_>, filename: &str, aiomgr: Arc<AIOManager> ) -> Result<Self, ()>

Trait Implementations

impl WALFile for WALFileAIO

fn allocate<'life0, 'async_trait>( &'life0 self, offset: WALPos, length: usize ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the file space in [offset, offset + length) to zero.

fn truncate(&self, length: usize) -> Result<(), ()>

Truncate a file to a specified length.

fn write<'life0, 'async_trait>( &'life0 self, offset: WALPos, data: WALBytes ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Write data with offset. We assume all previous allocate/truncate invocations are visible if ordered earlier (should be guaranteed by most OS). Additionally, the write caused by each invocation of this function should be atomic (the entire single write should be all or nothing).

fn read<'life0, 'async_trait>( &'life0 self, offset: WALPos, length: usize ) -> Pin<Box<dyn Future<Output = Result<Option<WALBytes>, ()>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read data with offset. Return Ok(None) when it reaches EOF.