Trait DynLogReader 

pub trait DynLogReader: Send {
    // Required methods
    fn dyn_start_from<'life0, 'async_trait>(
        &'life0 mut self,
        start_offset: Option<u64>,
    ) -> Pin<Box<dyn Future<Output = LogStoreResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn dyn_next_item<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn dyn_truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>;
}

Required Methods

fn dyn_start_from<'life0, 'async_trait>( &'life0 mut self, start_offset: Option<u64>, ) -> Pin<Box<dyn Future<Output = LogStoreResult<()>> + Send + 'async_trait>>

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

fn dyn_next_item<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + 'async_trait>>

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

fn dyn_truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>

Trait Implementations

impl SinkLogReader for &mut dyn DynLogReader

fn start_from( &mut self, start_offset: Option<u64>, ) -> impl Future<Output = LogStoreResult<()>> + Send + '_

fn next_item( &mut self, ) -> impl Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + '_

Emit the next item.

fn truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>

Mark that all items emitted so far have been consumed and it is safe to truncate the log from the current offset.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<R: SinkLogReader> DynLogReader for R