pub enum Command<K, V> {
Insert(K, V, u64),
BatchInsert(Vec<(K, V, u64)>),
Remove(K, u64),
Clear(Arc<OneshotAck>),
Sync(Arc<OneshotAck>),
Shutdown,
}Variants§
Insert(K, V, u64)
Single insert from Worker (goes through probation gate).
BatchInsert(Vec<(K, V, u64)>)
Batch of (K, V, hash) from sharded worker buffers.
Remove(K, u64)
Remove by key+hash.
Clear(Arc<OneshotAck>)
Blocking clear — caller spins on OneshotAck::wait().
Sync(Arc<OneshotAck>)
Blocking maintenance flush — caller spins on OneshotAck::wait().
Shutdown
Signal Daemon to exit its run loop.
Auto Trait Implementations§
impl<K, V> Freeze for Command<K, V>
impl<K, V> RefUnwindSafe for Command<K, V>where
K: RefUnwindSafe,
V: RefUnwindSafe,
impl<K, V> Send for Command<K, V>
impl<K, V> Sync for Command<K, V>
impl<K, V> Unpin for Command<K, V>
impl<K, V> UnsafeUnpin for Command<K, V>where
K: UnsafeUnpin,
V: UnsafeUnpin,
impl<K, V> UnwindSafe for Command<K, V>where
K: UnwindSafe,
V: 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