Struct ConcurrencyControl 

pub struct ConcurrencyControl { /* private fields */ }

Opt-in runtime enforcement of concurrency-anomaly gating for a coordination group. Attach one to crate::SharedInfra to have the isolated parallel swarm gate its merge barrier; absent, coordination behaves exactly as before (purely additive, matching the empty-default-gate-list stance in car-engine).

Carries the gate policy and a monotonic logical clock used to stamp each op’s read_at/commit_at, so the detector can tell which generate windows overlapped.

Implementations

impl ConcurrencyControl

pub fn new(policy: ConcurrencyGatePolicy) -> Self

Build with an explicit gate policy.

pub fn with_default_policy() -> Self

Build with the default policy: abort on L0 (causal-cascade), require approval on L1 (stale-generation), auto-remediate the rest.

pub fn policy(&self) -> &ConcurrencyGatePolicy

The gate policy in force.

pub fn tick(&self) -> u64

Next logical timestamp on the shared monotonic clock. Agents stamp read_at before they run and commit_at when they finish, so two agents that ran concurrently get overlapping [read_at, commit_at] windows.

pub async fn guard( &self, ops: &[AgentOp], log: &Arc<TokioMutex<EventLog>>, ) -> ConcurrencyGuard

Analyze ops, gate the report under this control’s policy, emit the audit event, and return a ConcurrencyGuard telling the caller what to do at the commit barrier. Pure aside from the single log append.

Trait Implementations

impl Clone for ConcurrencyControl

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.