Struct PrometheusMetrics

Source

pub struct PrometheusMetrics {Show 37 fields
    pub connections_total: IntCounter,
    pub connections_active: IntGauge,
    pub connections_by_user: IntGaugeVec,
    pub sessions_total: IntCounter,
    pub sessions_active: IntGauge,
    pub session_duration_seconds: Histogram,
    pub uplinks_total: IntGauge,
    pub uplinks_active: IntGauge,
    pub uplink_state: IntGaugeVec,
    pub uplink_health: GaugeVec,
    pub bytes_sent_total: IntCounterVec,
    pub bytes_received_total: IntCounterVec,
    pub packets_sent_total: IntCounterVec,
    pub packets_received_total: IntCounterVec,
    pub packets_dropped_total: IntCounterVec,
    pub packets_retransmitted_total: IntCounterVec,
    pub rtt_seconds: GaugeVec,
    pub rtt_histogram: HistogramVec,
    pub jitter_seconds: GaugeVec,
    pub packet_loss_ratio: GaugeVec,
    pub quality_score: GaugeVec,
    pub bandwidth_bytes_per_sec: GaugeVec,
    pub nat_type: IntGaugeVec,
    pub external_port: IntGaugeVec,
    pub active_flows: IntGauge,
    pub flow_bindings: IntGaugeVec,
    pub scheduler_selections_total: IntCounterVec,
    pub scheduler_latency_seconds: Histogram,
    pub handshakes_total: IntCounter,
    pub handshakes_failed: IntCounter,
    pub rekeys_total: IntCounter,
    pub encrypt_operations: IntCounter,
    pub decrypt_operations: IntCounter,
    pub errors_total: IntCounterVec,
    pub server_uptime_seconds: Gauge,
    pub users_total: IntGauge,
    pub users_active: IntGauge,
    /* private fields */
}

Expand description

Prometheus metrics registry and collectors.

Fields§

§connections_total: IntCounter§connections_active: IntGauge§connections_by_user: IntGaugeVec§sessions_total: IntCounter§sessions_active: IntGauge§session_duration_seconds: Histogram§uplinks_total: IntGauge§uplinks_active: IntGauge§uplink_state: IntGaugeVec§uplink_health: GaugeVec§bytes_sent_total: IntCounterVec§bytes_received_total: IntCounterVec§packets_sent_total: IntCounterVec§packets_received_total: IntCounterVec§packets_dropped_total: IntCounterVec§packets_retransmitted_total: IntCounterVec§rtt_seconds: GaugeVec§rtt_histogram: HistogramVec§jitter_seconds: GaugeVec§packet_loss_ratio: GaugeVec§quality_score: GaugeVec§bandwidth_bytes_per_sec: GaugeVec§nat_type: IntGaugeVec§external_port: IntGaugeVec§active_flows: IntGauge§flow_bindings: IntGaugeVec§scheduler_selections_total: IntCounterVec§scheduler_latency_seconds: Histogram§handshakes_total: IntCounter§handshakes_failed: IntCounter§rekeys_total: IntCounter§encrypt_operations: IntCounter§decrypt_operations: IntCounter§errors_total: IntCounterVec§server_uptime_seconds: Gauge§users_total: IntGauge§users_active: IntGauge

Struct PrometheusMetrics Copy item path

Fields§

Implementations§

impl PrometheusMetrics

pub fn new() -> Result<Self, Error>

pub fn encode(&self) -> Result<String, Error>

pub fn record_rtt(&self, uplink_id: &str, rtt: Duration)

pub fn record_packet_sent(&self, uplink_id: &str, bytes: u64)

pub fn record_packet_received(&self, uplink_id: &str, bytes: u64)

pub fn record_packet_dropped(&self, uplink_id: &str, reason: &str)

pub fn set_uplink_state(&self, uplink_id: &str, interface: &str, state: i64)

pub fn set_uplink_health(&self, uplink_id: &str, interface: &str, health: f64)

pub fn set_uplink_quality( &self, uplink_id: &str, loss: f64, score: f64, jitter_secs: f64, )

pub fn set_bandwidth(&self, uplink_id: &str, send_bps: f64, recv_bps: f64)

pub fn record_error(&self, error_type: &str)

pub fn record_scheduler_selection( &self, uplink_id: &str, strategy: &str, latency: Duration, )

Trait Implementations§

impl Default for PrometheusMetrics

fn default() -> Self

Auto Trait Implementations§

impl Freeze for PrometheusMetrics

impl !RefUnwindSafe for PrometheusMetrics

impl Send for PrometheusMetrics

impl Sync for PrometheusMetrics

impl Unpin for PrometheusMetrics

impl !UnwindSafe for PrometheusMetrics

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

Struct PrometheusMetrics

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,