Struct HolderRelayHook 

pub struct HolderRelayHook {
    pub clock: Arc<dyn Clock>,
}

Uses supplied observations only: no store/client exists in this hook.

Fields

clock: Arc<dyn Clock>

Clock used for fresh bounded commit deadlines.

Trait Implementations

impl Debug for HolderRelayHook

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RelayHook for HolderRelayHook

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.

fn before_apply<'a>( &'a self, _: &'a Partition, _: &'a [(u64, RelayV1)], _: &'a mut Vec<Precondition>, _: &'a mut Vec<Write>, ) -> BoxFuture<'a, Result<(), StoreError>>

Extend the atomic target batch, or fail delivery for this target.

fn before_apply_observed<'a>( &'a self, target: &'a Partition, rows: &'a [(u64, RelayV1)], seen: &'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.

fn reserved_ops(&self, _target: &Partition, _rows: &[(u64, RelayV1)]) -> usize

Target-local extensions may reserve operations before a remote apply. The relay shrinks groups until their base effects and this reserve fit.