pub struct WorkflowDeadlineHandler { /* private fields */ }Expand description
Records WorkflowTimedOut and tears down a run whose deadline elapsed.
Implementations§
Source§impl WorkflowDeadlineHandler
impl WorkflowDeadlineHandler
Sourcepub fn new(
runtime: Weak<RuntimeHandle>,
store: Arc<dyn EventStore>,
visibility_store: Arc<dyn VisibilityStore>,
registry: Arc<Registry>,
) -> Self
pub fn new( runtime: Weak<RuntimeHandle>, store: Arc<dyn EventStore>, visibility_store: Arc<dyn VisibilityStore>, registry: Arc<Registry>, ) -> Self
Assembles a deadline handler from the engine’s teardown dependencies.
runtime is held weakly on purpose (see the module docs); the rest are
the same durable store, visibility index, and active registry the
terminate::cancel path uses.
Trait Implementations§
Source§impl DeadlineHandler for WorkflowDeadlineHandler
impl DeadlineHandler for WorkflowDeadlineHandler
Source§fn on_deadline_elapsed<'life0, 'async_trait>(
&'life0 self,
workflow_id: WorkflowId,
run_id: RunId,
) -> Pin<Box<dyn Future<Output = Result<(), DeadlineHandlerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn on_deadline_elapsed<'life0, 'async_trait>(
&'life0 self,
workflow_id: WorkflowId,
run_id: RunId,
) -> Pin<Box<dyn Future<Output = Result<(), DeadlineHandlerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Auto Trait Implementations§
impl !RefUnwindSafe for WorkflowDeadlineHandler
impl !UnwindSafe for WorkflowDeadlineHandler
impl Freeze for WorkflowDeadlineHandler
impl Send for WorkflowDeadlineHandler
impl Sync for WorkflowDeadlineHandler
impl Unpin for WorkflowDeadlineHandler
impl UnsafeUnpin for WorkflowDeadlineHandler
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