Struct openraft::storage::LogFlushed
source · pub struct LogFlushed<C>where
C: RaftTypeConfig,{ /* private fields */ }
Expand description
A oneshot callback for completion of log io operation.
Implementations§
source§impl<C> LogFlushed<C>where
C: RaftTypeConfig,
impl<C> LogFlushed<C>where
C: RaftTypeConfig,
sourcepub fn log_io_completed(self, result: Result<(), Error>)
pub fn log_io_completed(self, result: Result<(), Error>)
Report log io completion event.
It will be called when the log is successfully appended to the storage or an error occurs.
Auto Trait Implementations§
impl<C> Freeze for LogFlushed<C>where
<<C as RaftTypeConfig>::AsyncRuntime as AsyncRuntime>::OneshotSender<Result<Option<LogId<<C as RaftTypeConfig>::NodeId>>, Error>>: Freeze,
<C as RaftTypeConfig>::NodeId: Freeze,
impl<C> RefUnwindSafe for LogFlushed<C>where
<<C as RaftTypeConfig>::AsyncRuntime as AsyncRuntime>::OneshotSender<Result<Option<LogId<<C as RaftTypeConfig>::NodeId>>, Error>>: RefUnwindSafe,
<C as RaftTypeConfig>::NodeId: RefUnwindSafe,
impl<C> Send for LogFlushed<C>
impl<C> Sync for LogFlushed<C>
impl<C> Unpin for LogFlushed<C>where
<<C as RaftTypeConfig>::AsyncRuntime as AsyncRuntime>::OneshotSender<Result<Option<LogId<<C as RaftTypeConfig>::NodeId>>, Error>>: Unpin,
<C as RaftTypeConfig>::NodeId: Unpin,
impl<C> UnwindSafe for LogFlushed<C>where
<<C as RaftTypeConfig>::AsyncRuntime as AsyncRuntime>::OneshotSender<Result<Option<LogId<<C as RaftTypeConfig>::NodeId>>, Error>>: UnwindSafe,
<C as RaftTypeConfig>::NodeId: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more