Struct FeedDiskPersistence 

pub struct FeedDiskPersistence { /* private fields */ }

Main constructor.

Implementations

impl RandomAccessDisk

pub async fn open( filename: impl AsRef<Path>, ) -> Result<RandomAccessDisk, RandomAccessError>

Create a new (auto-sync) instance to storage at filename.

pub fn builder(filename: impl AsRef<Path>) -> Builder

Initialize a builder with storage at filename.

Trait Implementations

impl Debug for RandomAccessDisk

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Drop for RandomAccessDisk

fn drop(&mut self)

Executes the destructor for this type.

impl RandomAccess for RandomAccessDisk

fn write<'life0, 'life1, 'async_trait>( &'life0 mut self, offset: u64, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, RandomAccessDisk: 'async_trait,

Write bytes of data at an offset to the backend.

fn read<'life0, 'async_trait>( &'life0 mut self, offset: u64, length: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RandomAccessDisk: 'async_trait,

Read a sequence of bytes at an offset from the backend.

fn del<'life0, 'async_trait>( &'life0 mut self, offset: u64, length: u64, ) -> Pin<Box<dyn Future<Output = Result<(), RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RandomAccessDisk: 'async_trait,

Delete a sequence of bytes of given length at an offset from the backend. This either sets the bytes in the given slice to zeroes, or if offset + length >= RandomAccess::len() is the same as truncate(offset).

fn truncate<'life0, 'async_trait>( &'life0 mut self, length: u64, ) -> Pin<Box<dyn Future<Output = Result<(), RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RandomAccessDisk: 'async_trait,

Resize the sequence of bytes so that RandomAccess::len() is set to length. If length < RandomAccess::len(), the bytes are disregarded. If length > RandomAccess::len(), the storage is zero-padded.

fn len<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<u64, RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RandomAccessDisk: 'async_trait,

Get the size of the storage in bytes.

fn is_empty<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<bool, RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RandomAccessDisk: 'async_trait,

Whether the storage is empty. For some storage backends it may be cheaper to calculate whether the storage is empty than to calculate the length.

fn sync_all<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), RandomAccessError>> + Send + 'async_trait>>

where 'life0: 'async_trait, RandomAccessDisk: 'async_trait,

Flush buffered data on the underlying storage resource.