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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

use crate::metrics::metrics_key::MetricsKey;
use crate::metrics::model::{MetricsItem, MetricsQuery, MetricsRecord};
use crate::naming::core::NamingActor;
use actix::Handler;

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

    fn handle(&mut self, _: MetricsQuery, _ctx: &mut Self::Context) -> Self::Result {
        let (group_size, service_size) = self.namespace_index.get_service_count();
        let list = vec![
            MetricsItem {
                metrics_type: MetricsKey::NamingServiceSize,
                record: MetricsRecord::Gauge(self.service_map.len() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingInstanceSize,
                record: MetricsRecord::Gauge(self.get_instance_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingSubscriberListenerKeySize,
                record: MetricsRecord::Gauge(self.subscriber.get_listener_key_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingSubscriberListenerValueSize,
                record: MetricsRecord::Gauge(self.subscriber.get_listener_value_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingSubscriberClientSize,
                record: MetricsRecord::Gauge(self.subscriber.get_client_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingSubscriberClientValueSize,
                record: MetricsRecord::Gauge(self.subscriber.get_client_value_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingEmptyServiceSetSize,
                record: MetricsRecord::Gauge(self.empty_service_set.len() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingEmptyServiceSetItemSize,
                record: MetricsRecord::Gauge(self.empty_service_set.item_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingInstanceMetaSetSize,
                record: MetricsRecord::Gauge(self.instance_metadate_set.len() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingInstanceMetaSetItemSize,
                record: MetricsRecord::Gauge(self.instance_metadate_set.item_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingHealthyTimeoutSetSize,
                record: MetricsRecord::Gauge(self.get_healthy_timeout_set_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingHealthyTimeoutSetItemSize,
                record: MetricsRecord::Gauge(self.get_healthy_timeout_set_item_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingUnhealthyTimeoutSetSize,
                record: MetricsRecord::Gauge(self.get_unhealthy_timeout_set_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingUnhealthyTimeoutSetItemSize,
                record: MetricsRecord::Gauge(self.get_unhealthy_timeout_set_item_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingClientInstanceSetKeySize,
                record: MetricsRecord::Gauge(self.client_instance_set.len() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingClientInstanceSetValueSize,
                record: MetricsRecord::Gauge(self.get_client_instance_set_item_size() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingIndexTenantSize,
                record: MetricsRecord::Gauge(self.namespace_index.get_tenant_count() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingIndexGroupSize,
                record: MetricsRecord::Gauge(group_size as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::NamingIndexServiceSize,
                record: MetricsRecord::Gauge(service_size as f32),
            },
        ];
        Ok(list)
    }
}