pub struct SystemAudit<S> { /* private fields */ }Expand description
Source-local audit enqueue planner. No target effect happens before commit.
Implementations§
Source§impl<S> SystemAudit<S>
impl<S> SystemAudit<S>
Sourcepub fn new(store: S, root: Partition) -> Self
pub fn new(store: S, root: Partition) -> Self
Use the same root as the deployment admin engine and relay audit hook.
Sourcepub fn relay_row(
&self,
source: &Partition,
request: &Request,
operation_id: &str,
now_ms: u64,
) -> Result<RelayV1, StoreError>
pub fn relay_row( &self, source: &Partition, request: &Request, operation_id: &str, now_ms: u64, ) -> Result<RelayV1, StoreError>
Produce an event for callers already allocating source relay sequences.
Add this row to the same OutboxBuilder/enqueue_relay_rows allocation as
other effects; do not merge independently allocated os batches.
§Errors
Invalid automatic operation, selectors, source identity, or storage bounds.
Trait Implementations§
Source§impl<S: NamespaceStore> AutomaticAudit for SystemAudit<S>
impl<S: NamespaceStore> AutomaticAudit for SystemAudit<S>
Source§fn plan<'a>(
&'a self,
partition: &'a Partition,
request: &'a Request,
operation_id: &'a str,
now_ms: u64,
snapshot: RelayEnqueueSnapshot,
) -> BoxFuture<'a, Result<Batch, StoreError>>
fn plan<'a>( &'a self, partition: &'a Partition, request: &'a Request, operation_id: &'a str, now_ms: u64, snapshot: RelayEnqueueSnapshot, ) -> BoxFuture<'a, Result<Batch, StoreError>>
Returned effects belong to
partition; the caller atomically commits
these source-local relay rows alongside the automatic purge intent.
Use the caller’s charged source snapshot; planning must not read a
captured source store or issue a Durable Object self-call.Source§impl<S: Clone> Clone for SystemAudit<S>
impl<S: Clone> Clone for SystemAudit<S>
Auto Trait Implementations§
impl<S> Freeze for SystemAudit<S>where
S: Freeze,
impl<S> RefUnwindSafe for SystemAudit<S>where
S: RefUnwindSafe,
impl<S> Send for SystemAudit<S>where
S: Send,
impl<S> Sync for SystemAudit<S>where
S: Sync,
impl<S> Unpin for SystemAudit<S>where
S: Unpin,
impl<S> UnsafeUnpin for SystemAudit<S>where
S: UnsafeUnpin,
impl<S> UnwindSafe for SystemAudit<S>where
S: 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