Struct FeedMemoryPersistence 

pub struct FeedMemoryPersistence { /* private fields */ }

In-memory storage for random access

Implementations

impl RandomAccessMemory

pub fn new(page_size: usize) -> RandomAccessMemory

Create a new instance with page_size in bytes.

pub fn with_buffers( page_size: usize, buffers: IntMap<Vec<u8>>, ) -> RandomAccessMemory

Create a new instance with page_size in bytes, but pass the initial buffers to the constructor.

Trait Implementations

impl Debug for RandomAccessMemory

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

Formats the value using the given formatter.

impl Default for RandomAccessMemory

fn default() -> RandomAccessMemory

Create a new instance with a 1mb page size.

impl RandomAccess for RandomAccessMemory

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, RandomAccessMemory: 'async_trait,

Write bytes of data at an offset to the backend.

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

where 'life0: 'async_trait, RandomAccessMemory: 'async_trait,

Flush buffered data on the underlying storage resource.

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, RandomAccessMemory: '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, RandomAccessMemory: '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, RandomAccessMemory: '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, RandomAccessMemory: '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, RandomAccessMemory: '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.