Struct AuditRelayHook 

pub struct AuditRelayHook<S> { /* private fields */ }

Native relay hook: extend the actual atomic target apply after bounded reads.

Implementations

impl<S> AuditRelayHook<S>

pub fn new(store: S, root: Partition) -> Self

The target metadata store and canonical admin root.

Trait Implementations

impl<S: Clone> Clone for AuditRelayHook<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug> Debug for AuditRelayHook<S>

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

Formats the value using the given formatter.

impl<S: NamespaceStore> RelayHook for AuditRelayHook<S>

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.

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_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.

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.