pub struct DistributedReplayEngine { /* private fields */ }Expand description
One causal distributed replay engine built from a validated plan.
Implementations§
Source§impl DistributedReplayEngine
impl DistributedReplayEngine
Sourcepub fn reset(&mut self) -> CuResult<()>
pub fn reset(&mut self) -> CuResult<()>
Reset all replay sessions and graph execution state back to the beginning.
Sourcepub fn step_causal(&mut self) -> CuResult<Option<DistributedReplayCursor>>
pub fn step_causal(&mut self) -> CuResult<Option<DistributedReplayCursor>>
Replay the next causally ready CopperList, if any.
Sourcepub fn goto(
&mut self,
instance_id: u32,
subsystem_id: &str,
cl_id: u64,
) -> CuResult<()>
pub fn goto( &mut self, instance_id: u32, subsystem_id: &str, cl_id: u64, ) -> CuResult<()>
Rebuild the replay from scratch and advance until the target CopperList is reached.
Sourcepub fn current_frontier(&self) -> Vec<DistributedReplayCursor>
pub fn current_frontier(&self) -> Vec<DistributedReplayCursor>
Return the latest executed CopperList cursor for each replay session.
pub fn output_log_path( &self, instance_id: u32, subsystem_id: &str, ) -> Option<&Path>
pub fn total_nodes(&self) -> usize
pub fn executed_nodes(&self) -> usize
Auto Trait Implementations§
impl Freeze for DistributedReplayEngine
impl !RefUnwindSafe for DistributedReplayEngine
impl !Send for DistributedReplayEngine
impl !Sync for DistributedReplayEngine
impl Unpin for DistributedReplayEngine
impl UnsafeUnpin for DistributedReplayEngine
impl !UnwindSafe for DistributedReplayEngine
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
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