pub struct RecurStep {
pub interval: Duration,
pub stop_condition: bool,
}Expand description
A step that repeatedly schedules child execution at an interval until a stop condition is met.
Fields§
§interval: DurationInterval.
stop_condition: boolStop condition.
Trait Implementations§
Source§impl StepBody for RecurStep
impl StepBody for RecurStep
Source§fn run<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
context: &'life1 StepExecutionContext<'life2>,
) -> Pin<Box<dyn Future<Output = Result<ExecutionResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn run<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
context: &'life1 StepExecutionContext<'life2>,
) -> Pin<Box<dyn Future<Output = Result<ExecutionResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Execute the step. Read more
Source§fn mount_artifacts<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
_context: &'life1 StepExecutionContext<'life2>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn mount_artifacts<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
_context: &'life1 StepExecutionContext<'life2>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Mount any artifacts this step requires. Read more
Source§fn unmount_artifacts<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
_context: &'life1 StepExecutionContext<'life2>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn unmount_artifacts<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
_context: &'life1 StepExecutionContext<'life2>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Unmount and clean up artifacts. Read more
Auto Trait Implementations§
impl Freeze for RecurStep
impl RefUnwindSafe for RecurStep
impl Send for RecurStep
impl Sync for RecurStep
impl Unpin for RecurStep
impl UnsafeUnpin for RecurStep
impl UnwindSafe for RecurStep
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