rnacos 0.8.3

Nacos server re-implemented in Rust.
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
46
47
48
49
50

use crate::config::core::ConfigActor;
use crate::metrics::metrics_key::MetricsKey;
use crate::metrics::model::{MetricsItem, MetricsQuery, MetricsRecord};
use actix::prelude::*;

impl Handler<MetricsQuery> for ConfigActor {
    type Result = anyhow::Result<Vec<MetricsItem>>;

    fn handle(&mut self, _msg: MetricsQuery, _ctx: &mut Self::Context) -> Self::Result {
        let list = vec![
            MetricsItem {
                metrics_type: MetricsKey::ConfigDataSize,
                record: MetricsRecord::Gauge(self.cache.len() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigListenerClientSize,
                record: MetricsRecord::Gauge(self.listener.get_listener_client_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigListenerKeySize,
                record: MetricsRecord::Gauge(self.listener.get_listener_key_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigSubscriberListenerKeySize,
                record: MetricsRecord::Gauge(self.subscriber.get_listener_key_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigSubscriberListenerValueSize,
                record: MetricsRecord::Gauge(self.subscriber.get_listener_key_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigSubscriberClientSize,
                record: MetricsRecord::Gauge(self.subscriber.get_client_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigSubscriberClientValueSize,
                record: MetricsRecord::Gauge(self.subscriber.get_client_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigIndexTenantSize,
                record: MetricsRecord::Gauge(self.tenant_index.get_tenant_count() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::ConfigIndexConfigSize,
                record: MetricsRecord::Gauge(self.tenant_index.get_config_count().1 as f32),
            },
        ];
        Ok(list)
    }
}