pub struct NoHook;Expand description
Default hook: adds nothing.
Trait Implementations§
impl Copy for NoHook
Source§impl RelayHook for NoHook
impl RelayHook for NoHook
Source§fn before_apply<'a>(
&'a self,
_target: &'a Partition,
_rows: &'a [(u64, RelayV1)],
_pre: &'a mut Vec<Precondition>,
_writes: &'a mut Vec<Write>,
) -> BoxFuture<'a, Result<(), StoreError>>
fn before_apply<'a>( &'a self, _target: &'a Partition, _rows: &'a [(u64, RelayV1)], _pre: &'a mut Vec<Precondition>, _writes: &'a mut Vec<Write>, ) -> BoxFuture<'a, Result<(), StoreError>>
Extend the atomic target batch, or fail delivery for this target.
Source§fn read_keys(
&self,
_target: &Partition,
_rows: &[(u64, RelayV1)],
) -> Result<Vec<Key>, StoreError>
fn read_keys( &self, _target: &Partition, _rows: &[(u64, RelayV1)], ) -> Result<Vec<Key>, StoreError>
Additional raw observations, batched with the target watermark read.
The delivery engine deduplicates and bounds this declaration before IO.
Source§fn before_apply_observed<'a>(
&'a self,
target: &'a Partition,
rows: &'a [(u64, RelayV1)],
_observed: &'a [(Key, Option<Value>)],
pre: &'a mut Vec<Precondition>,
writes: &'a mut Vec<Write>,
) -> BoxFuture<'a, Result<(), StoreError>>
fn before_apply_observed<'a>( &'a self, target: &'a Partition, rows: &'a [(u64, RelayV1)], _observed: &'a [(Key, Option<Value>)], pre: &'a mut Vec<Precondition>, writes: &'a mut Vec<Write>, ) -> BoxFuture<'a, Result<(), StoreError>>
Extend using the declared snapshot, without hidden IO. Older hooks
retain their original callback; production content hooks override this.
Auto Trait Implementations§
impl Freeze for NoHook
impl RefUnwindSafe for NoHook
impl Send for NoHook
impl Sync for NoHook
impl Unpin for NoHook
impl UnsafeUnpin for NoHook
impl UnwindSafe for NoHook
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