pub struct TimeTravelOptions { /* private fields */ }Expand description
Selects a historical point from which crate::Client::time_travel re-runs a Flow.
Time travel keeps the run ID and starts the next run attempt of that run.
Constructors identify exactly one time travel point. Builder methods add an audit reason and control whether writes are reapplied. Write reapplication defaults to enabled.
Implementations§
Source§impl TimeTravelOptions
impl TimeTravelOptions
Sourcepub fn from_beginning() -> Self
pub fn from_beginning() -> Self
Resumes before the first workflow-history event.
Sourcepub fn from_history_event_time(event_time: SystemTime) -> Self
pub fn from_history_event_time(event_time: SystemTime) -> Self
Resumes at the last eligible history event at or before event_time.
Sourcepub fn from_step<SomeStep: Step>(step: &SomeStep) -> Self
pub fn from_step<SomeStep: Step>(step: &SomeStep) -> Self
Resumes before the first execution of the selected Step type.
Sourcepub fn from_step_execution(
step_execution: StepExecutionId,
method: TimeTravelStepMethod,
) -> Self
pub fn from_step_execution( step_execution: StepExecutionId, method: TimeTravelStepMethod, ) -> Self
Resumes before one method of the exact Step execution identified by step_execution.
Sourcepub fn reason(self, reason: impl Into<String>) -> Self
pub fn reason(self, reason: impl Into<String>) -> Self
Adds an operator-facing reason recorded with time travel.
Sourcepub fn skip_writes_reapply(self, skip: bool) -> Self
pub fn skip_writes_reapply(self, skip: bool) -> Self
Controls whether later RPCs, Channel publications, and Attribute writes are skipped.
Trait Implementations§
Source§impl Clone for TimeTravelOptions
impl Clone for TimeTravelOptions
Auto Trait Implementations§
impl Forget for TimeTravelOptions
impl Freeze for TimeTravelOptions
impl RefUnwindSafe for TimeTravelOptions
impl Send for TimeTravelOptions
impl Sync for TimeTravelOptions
impl Unpin for TimeTravelOptions
impl UnsafeUnpin for TimeTravelOptions
impl UnwindSafe for TimeTravelOptions
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request