pub trait SinkLogReader: Send {
// Required methods
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 + '_;
fn truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>;
}Required Methods§
fn start_from( &mut self, start_offset: Option<u64>, ) -> impl Future<Output = LogStoreResult<()>> + Send + '_
Sourcefn next_item(
&mut self,
) -> impl Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + '_
fn next_item( &mut self, ) -> impl Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + '_
Emit the next item.
The implementation should ensure that the future is cancellation safe.
Sourcefn truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>
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 not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.