pub struct CrossMemoryConsistencyManager { /* private fields */ }Expand description
Thread-safe manager implementing the Cross-Memory Consistency Layer (CMCL).
Implementations§
Source§impl CrossMemoryConsistencyManager
impl CrossMemoryConsistencyManager
Sourcepub const fn with_dharma_enforcement(self, enforce: bool) -> Self
pub const fn with_dharma_enforcement(self, enforce: bool) -> Self
Configure whether Dharma governance authorization is strictly enforced.
Sourcepub fn register_uncommitted_barrier(&mut self, op_id: &str)
pub fn register_uncommitted_barrier(&mut self, op_id: &str)
Mark an operation ID as an active uncommitted crash barrier.
Sourcepub fn commit_barrier(&mut self, op_id: &str)
pub fn commit_barrier(&mut self, op_id: &str)
Commit or clear an operation ID’s crash barrier.
Sourcepub fn is_uncommitted(&self, op_id: &str) -> bool
pub fn is_uncommitted(&self, op_id: &str) -> bool
Check if an operation ID is currently uncommitted.
Sourcepub const fn global_clock(&self) -> &VectorClock
pub const fn global_clock(&self) -> &VectorClock
Retrieve the current active vector clock.
Sourcepub fn coherence_ratio(&self) -> f32
pub fn coherence_ratio(&self) -> f32
Compute current coherence ratio (0.0 to 1.0) based on uncommitted barrier load.
Trait Implementations§
Source§impl CrossMemoryConsistency for CrossMemoryConsistencyManager
impl CrossMemoryConsistency for CrossMemoryConsistencyManager
Source§fn record_write(
&mut self,
op: &WriteOp,
) -> Result<CoherenceReceipt, ConsistencyError>
fn record_write( &mut self, op: &WriteOp, ) -> Result<CoherenceReceipt, ConsistencyError>
Verify and record a cross-galaxy write, updating causal clocks.
Source§fn verify_causal_read(
&self,
galaxy: Galaxy,
required_clock: &VectorClock,
) -> Result<(), ConsistencyError>
fn verify_causal_read( &self, galaxy: Galaxy, required_clock: &VectorClock, ) -> Result<(), ConsistencyError>
Check if reading from
galaxy satisfies the caller’s required vector clock.Source§fn resolve_conflict(
&mut self,
conflict: &ConflictReport,
strategy: Resolution,
) -> CoherenceReceipt
fn resolve_conflict( &mut self, conflict: &ConflictReport, strategy: Resolution, ) -> CoherenceReceipt
Resolve a concurrent mutation conflict.
Source§fn snapshot(&self) -> CoherenceSnapshot
fn snapshot(&self) -> CoherenceSnapshot
Retrieve the current point-in-time coherence snapshot.
Auto Trait Implementations§
impl Freeze for CrossMemoryConsistencyManager
impl RefUnwindSafe for CrossMemoryConsistencyManager
impl Send for CrossMemoryConsistencyManager
impl Sync for CrossMemoryConsistencyManager
impl Unpin for CrossMemoryConsistencyManager
impl UnsafeUnpin for CrossMemoryConsistencyManager
impl UnwindSafe for CrossMemoryConsistencyManager
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Converts
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Converts
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Converts
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Converts
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> DowncastSend for T
impl<T> DowncastSend for T
Source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
impl<T> Fruit for T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more