Trait InterceptService 

pub trait InterceptService: Send + Sync {
    // Required methods
    fn register_intercept<'life0, 'async_trait>(
        &'life0 self,
        key: String,
        tx: Sender<InterceptionResult>,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn resolve_intercept_with_modifications_from<'life0, 'life1, 'async_trait>(
        &'life0 self,
        actor: AuditActor,
        key: String,
        action: &'life1 str,
        mods: Option<FlowModification>,
    ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn is_flow_intercepted<'life0, 'async_trait>(
        &'life0 self,
        flow_id: String,
    ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn intercept_snapshot<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = CoreInterceptSnapshot> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn register_intercept<'life0, 'async_trait>( &'life0 self, key: String, tx: Sender<InterceptionResult>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

fn resolve_intercept_with_modifications_from<'life0, 'life1, 'async_trait>( &'life0 self, actor: AuditActor, key: String, action: &'life1 str, mods: Option<FlowModification>, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

fn is_flow_intercepted<'life0, 'async_trait>( &'life0 self, flow_id: String, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

fn intercept_snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreInterceptSnapshot> + Send + 'async_trait>>

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

Implementors

impl InterceptService for CoreState