pub struct WorkflowReplayer { /* private fields */ }Expand description
Replays workflow histories against registered workflow implementations.
Implementations§
Source§impl WorkflowReplayer
impl WorkflowReplayer
Sourcepub fn new(
options: WorkflowReplayerOptions,
) -> Result<Self, WorkflowReplayError>
pub fn new( options: WorkflowReplayerOptions, ) -> Result<Self, WorkflowReplayError>
Construct a replayer and apply its worker plugins.
Sourcepub fn options(&self) -> &WorkflowReplayerOptions
pub fn options(&self) -> &WorkflowReplayerOptions
Return the configured replay options.
Sourcepub async fn replay_workflow(
&self,
history: WorkflowHistory,
) -> Result<(), WorkflowReplayError>
pub async fn replay_workflow( &self, history: WorkflowHistory, ) -> Result<(), WorkflowReplayError>
Replay one history and return an error if it is incompatible with workflow code.
Sourcepub async fn replay_workflows(
&self,
histories: impl IntoIterator<Item = WorkflowHistory>,
) -> Result<Vec<WorkflowReplayResult>, WorkflowReplayError>
pub async fn replay_workflows( &self, histories: impl IntoIterator<Item = WorkflowHistory>, ) -> Result<Vec<WorkflowReplayResult>, WorkflowReplayError>
Replay histories using one replay worker and return outcomes in input order.
Auto Trait Implementations§
impl !RefUnwindSafe for WorkflowReplayer
impl !UnwindSafe for WorkflowReplayer
impl Freeze for WorkflowReplayer
impl Send for WorkflowReplayer
impl Sync for WorkflowReplayer
impl Unpin for WorkflowReplayer
impl UnsafeUnpin for WorkflowReplayer
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> 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 moreSource§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