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

use async_trait::async_trait;
use tokio::sync::watch;
use crate::{CoreMetrics, CoreState, CoreStatusReport, CoreStatusSnapshot, RuntimeLifecycle};

#[async_trait]
pub trait RuntimeStatusService: Send + Sync {
    fn status_snapshot(&self) -> CoreStatusSnapshot;
    async fn status_report(&self) -> CoreStatusReport;
    async fn get_metrics(&self) -> CoreMetrics;
    async fn get_metrics_prometheus_text(&self) -> String;
    fn subscribe_lifecycle(&self) -> watch::Receiver<RuntimeLifecycle>;
}

#[async_trait]
impl RuntimeStatusService for CoreState {
    fn status_snapshot(&self) -> CoreStatusSnapshot {
        CoreState::status_snapshot(self)
    }

    async fn status_report(&self) -> CoreStatusReport {
        CoreState::status_report(self).await
    }

    async fn get_metrics(&self) -> CoreMetrics {
        CoreState::get_metrics(self).await
    }

    async fn get_metrics_prometheus_text(&self) -> String {
        CoreState::get_metrics_prometheus_text(self).await
    }

    fn subscribe_lifecycle(&self) -> watch::Receiver<RuntimeLifecycle> {
        CoreState::subscribe_lifecycle(self)
    }
}