pub enum LogCommand {
WaitDurable(u64, Sender<()>),
PersistEntries(Vec<u64>),
Flush(Sender<Result<()>>),
Reset(Sender<Result<()>>),
Shutdown,
}Expand description
Commands for the log processor
Variants§
WaitDurable(u64, Sender<()>)
Request to wait until specific index is durable
PersistEntries(Vec<u64>)
Request to persist specific log entries
Flush(Sender<Result<()>>)
Trigger immediate flush with result notification
Reset(Sender<Result<()>>)
Reset the log storage
Shutdown
Shutdown command processor
Trait Implementations§
Auto Trait Implementations§
impl Freeze for LogCommand
impl !RefUnwindSafe for LogCommand
impl Send for LogCommand
impl Sync for LogCommand
impl Unpin for LogCommand
impl !UnwindSafe for LogCommand
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request