relay-core-runtime 0.1.2

High-performance Rust traffic interception engine and proxy platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use async_trait::async_trait;
use tokio::sync::oneshot;
use relay_core_api::modification::FlowModification;
use relay_core_lib::InterceptionResult;
use crate::audit::AuditActor;
use crate::{CoreInterceptSnapshot, CoreState};

#[async_trait]
pub trait InterceptService: Send + Sync {
    async fn register_intercept(&self, key: String, tx: oneshot::Sender<InterceptionResult>);
    async fn resolve_intercept_with_modifications_from(
        &self,
        actor: AuditActor,
        key: String,
        action: &str,
        mods: Option<FlowModification>,
    ) -> Result<(), String>;
    async fn is_flow_intercepted(&self, flow_id: String) -> bool;
    async fn intercept_snapshot(&self) -> CoreInterceptSnapshot;
}

#[async_trait]
impl InterceptService for CoreState {
    async fn register_intercept(&self, key: String, tx: oneshot::Sender<InterceptionResult>) {
        CoreState::register_intercept(self, key, tx).await
    }

    async fn resolve_intercept_with_modifications_from(
        &self,
        actor: AuditActor,
        key: String,
        action: &str,
        mods: Option<FlowModification>,
    ) -> Result<(), String> {
        CoreState::resolve_intercept_with_modifications_from(self, actor, key, action, mods).await
    }

    async fn is_flow_intercepted(&self, flow_id: String) -> bool {
        CoreState::is_flow_intercepted(self, flow_id).await
    }

    async fn intercept_snapshot(&self) -> CoreInterceptSnapshot {
        CoreState::intercept_snapshot(self).await
    }
}