Struct InterceptorWithNext 

pub struct InterceptorWithNext { /* private fields */ }

Supports the composition of interceptors

Implementations

impl InterceptorWithNext

pub fn new(inner: Box<dyn WorkerInterceptor>) -> Self

Create from an existing interceptor, can be used to initialize a chain of interceptors

pub fn set_next( &mut self, next: Box<dyn WorkerInterceptor>, ) -> &mut InterceptorWithNext

Sets the next interceptor, and then returns that interceptor, wrapped by InterceptorWithNext. You can keep calling this method on it to extend the chain.

Trait Implementations

impl WorkerInterceptor for InterceptorWithNext

fn on_workflow_activation_completion<'life0, 'life1, 'async_trait>( &'life0 self, c: &'life1 WorkflowActivationCompletion, ) -> Pin<Box<dyn Future<Output = ()> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called every time a workflow activation completes (just before sending the completion to core).

fn on_shutdown(&self, w: &Worker)

Called after the worker has initiated shutdown and the workflow/activity polling loops have exited, but just before waiting for the inner core worker shutdown

fn on_workflow_activation<'life0, 'life1, 'async_trait>( &'life0 self, a: &'life1 WorkflowActivation, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called every time a workflow is about to be activated