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.

Implementors

impl<R: SinkLogReader> DynLogReader for R