Struct ConcurrencyGuard 

pub struct ConcurrencyGuard {
    pub report: ConcurrencyReport,
    pub gate: ConcurrencyGate,
    pub abort: bool,
    pub rejected_ops: HashSet<String>,
}

The commit-barrier decision derived from a gated ConcurrencyReport.

Fields

report: ConcurrencyReport

The raw detector report (level + every anomaly found).

gate: ConcurrencyGate

The gate’s per-anomaly remediations and dispositions.

abort: bool

True when the whole batch must abort (any Abort disposition). No op is committed when set.

rejected_ops: HashSet<String>

Op ids whose individual commit must be rejected (fail-closed RequireApproval, no approval sink). Their writes are not merged.

Implementations

impl ConcurrencyGuard

pub fn is_clean(&self) -> bool

True when the schedule was serializable — nothing to gate.

pub fn may_commit(&self, op_id: &str) -> bool

Should the op with this id have its writes committed? False when the whole batch aborts or this specific op was rejected for approval.

pub fn rejection_reason(&self, op_id: &str) -> Option<String>

A human-readable reason a specific op was held back, for the errored output surfaced to the caller.

pub fn anomaly_summary(&self) -> String

One-line summary of the anomalies found, for logs and errors.

Trait Implementations

impl Clone for ConcurrencyGuard

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 ConcurrencyGuard

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

Formats the value using the given formatter.