Struct laminarmq::storage::impls::glommio::storage::dma::DmaStorage

pub struct DmaStorage { /* private fields */ }

Implementations

impl DmaStorage

pub async fn new<P: AsRef<Path>>(path: P) -> Result<Self, DmaStorageError>

pub async fn with_storage_path_and_buffer_size<P: AsRef<Path>>( path: P, buffer_size: usize ) -> Result<Self, DmaStorageError>

Trait Implementations

impl AsyncConsume for DmaStorage

type ConsumeError = DmaStorageError

Error that can occur during a consumption operation.

fn remove<'async_trait>( self ) -> Pin<Box<dyn Future<Output = Result<(), Self::ConsumeError>> + 'async_trait>>where Self: 'async_trait,

Removes all storage associated with this collection.

fn close<'async_trait>( self ) -> Pin<Box<dyn Future<Output = Result<(), Self::ConsumeError>> + 'async_trait>>where Self: 'async_trait,

Closes this collection.

impl AsyncTruncate for DmaStorage

type Mark = u64

Type to denote a truncation “mark”, after which the collection will be truncated.

type TruncError = DmaStorageError

Error that can occur during a truncation operation.

fn truncate<'life0, 'life1, 'async_trait>( &'life0 mut self, position: &'life1 Self::Mark ) -> Pin<Box<dyn Future<Output = Result<(), Self::TruncError>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Truncates this collection after the given mark, such that this collection contains records only upto this “mark”.

impl Debug for DmaStorage

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

Formats the value using the given formatter.

impl PathAddressedStorageProvider<DmaStorage> for DmaStorageProvider

fn obtain_storage<'life0, 'async_trait, P>( &'life0 self, path: P ) -> Pin<Box<dyn Future<Output = Result<DmaStorage, DmaStorageError>> + 'async_trait>>where P: 'async_trait + AsRef<Path>, Self: 'async_trait, 'life0: 'async_trait,

impl Sizable for DmaStorage

type Size = u64

Type to represent the size of this collection in number of bytes.

fn size(&self) -> Self::Size

Returns the size of this collection in butes.

impl Storage for DmaStorage

type Content = ReadResult

Type to represent the content bytes of this storage media.

type Position = u64

Type to represent data positions inside this storage media.

type Error = DmaStorageError

Error that can occur during storage operations.

fn append_slice<'life0, 'life1, 'async_trait>( &'life0 mut self, slice: &'life1 [u8] ) -> Pin<Box<dyn Future<Output = Result<(Self::Position, Self::Size), Self::Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Appends the given slice of bytes to the end of this storage.

fn read<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, position: &'life1 Self::Position, size: &'life2 Self::Size ) -> Pin<Box<dyn Future<Output = Result<Self::Content, Self::Error>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Reads size number of bytes from the given position.

fn append<'life0, 'life1, 'async_trait, XBuf, XE, X>( &'life0 mut self, buf_stream: &'life1 mut X, append_threshold: Option<Self::Size> ) -> Pin<Box<dyn Future<Output = Result<(Self::Position, Self::Size), Self::Error>> + 'async_trait>>where XBuf: Deref<Target = [u8]> + 'async_trait, X: Stream<Item = Result<XBuf, XE>> + Unpin + 'async_trait, XE: 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Appends a stream of byte slices to the end of this storage.