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
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§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.§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.§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.§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> 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