Struct SyncFaultBlob 

pub struct SyncFaultBlob<B> { /* private fields */ }

Blob wrapper that fails sync and start_sync when marked faulty.

Trait Implementations

impl<B: Blob> Blob for SyncFaultBlob<B>

async fn read_at_buf( &self, offset: u64, len: usize, bufs: impl Into<IoBufsMut> + Send, ) -> Result<IoBufsMut, Error>

Read len bytes at offset into caller-provided buffer(s).

async fn read_at(&self, offset: u64, len: usize) -> Result<IoBufsMut, Error>

Read len bytes at offset, returning a buffer(s) with exactly len bytes of data read from the blob starting at offset.

async fn write_at( &self, offset: u64, bufs: impl Into<IoBufs> + Send, ) -> Result<(), Error>

Write bufs to the blob at the given offset.

async fn write_at_sync( &self, offset: u64, bufs: impl Into<IoBufs> + Send, ) -> Result<(), Error>

Write bufs to the blob at the given offset and durably persist that write.

async fn resize(&self, len: u64) -> Result<(), Error>

Resize the blob to the given length.

async fn sync(&self) -> Result<(), Error>

Ensure all pending data is durably persisted.

async fn start_sync(&self) -> Handle<()>

Request that all pending data is durably persisted.

impl<B: Clone> Clone for SyncFaultBlob<B>

fn clone(&self) -> SyncFaultBlob<B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.