Struct AuditReserveHook 

pub struct AuditReserveHook { /* private fields */ }

Worker relay hook reserves target-local SQL extension space without DO reads.

Implementations

impl AuditReserveHook

pub fn new(root: Partition) -> Self

The canonical admin root extended inside the target SQL transaction.

Trait Implementations

impl Clone for AuditReserveHook

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AuditReserveHook

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

Formats the value using the given formatter.

impl RelayHook for AuditReserveHook

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.

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.