增加监控度量模块，增加CounterManager #64

src/lib.rs

@@ -9,6 +9,7 @@ pub mod starter;
 pub mod user;
 pub mod utils;
 pub mod web_config;
+pub mod metrics;
 
 pub use inner_mem_cache::TimeoutSet;
 

src/metrics/core.rs

@@ -0,0 +1,19 @@
+use std::collections::HashMap;
+use crate::metrics::metrics_type::MetricsType;
+
+pub struct CounterManager{
+    date_map : HashMap<MetricsType,u64>,
+}
+
+pub struct GaugeManager{
+    date_map : HashMap<MetricsType,u64>,
+}
+
+pub struct HistogramManager {
+
+}
+
+pub struct MetricsManager{
+    //counter: CounterManager,
+
+}

src/metrics/counter.rs

@@ -0,0 +1,60 @@
+use std::collections::HashMap;
+use crate::metrics::metrics_type::MetricsType;
+
+
+#[derive(Default,Debug)]
+pub struct CounterItem(u64);
+
+impl CounterItem {
+    pub fn increment(&mut self, value: u64) {
+        self.0 += value;
+    }
+
+    pub fn absolute(&mut self, value: u64) {
+        self.0 = value;
+    }
+
+    pub fn value(&self) -> u64 {
+        self.0
+    }
+}
+
+impl From<CounterItem> for u64 {
+    fn from(value: CounterItem) -> Self {
+        value.0
+    }
+}
+
+impl From<u64> for CounterItem {
+    fn from(value: u64) -> Self {
+        Self(value)
+    }
+}
+
+type Key = MetricsType;
+
+#[derive(Default,Debug)]
+pub struct CounterManager{
+    date_map : HashMap<Key,CounterItem>,
+}
+
+impl CounterManager {
+    pub fn increment(&mut self,key:Key,value:u64) {
+        if let Some(item) = self.date_map.get_mut(&key) {
+            item.increment(value);
+        }
+        else {
+            self.date_map.insert(key,value.into());
+        }
+    }
+
+    pub fn absolute(&mut self,key:Key,value:u64) {
+        if let Some(item) = self.date_map.get_mut(&key) {
+            item.absolute(value);
+        }
+        else {
+            self.date_map.insert(key,value.into());
+        }
+    }
+}
+

src/metrics/gauge.rs

@@ -0,0 +1,6 @@
+use std::collections::HashMap;
+use crate::metrics::metrics_type::MetricsType;
+
+pub struct GaugeManager{
+    date_map : HashMap<MetricsType,u64>,
+}

src/metrics/histogram.rs

@@ -0,0 +1,5 @@
+
+
+pub struct HistogramManager {
+
+}

src/metrics/metrics_type.rs

@@ -0,0 +1,13 @@
+
+#[derive(Debug, Eq, PartialEq, Clone, Hash)]
+pub enum MetricsType {
+    None,
+    ConfigDataSize,
+    ConfigListenerSize,
+}
+
+impl Default for MetricsType {
+    fn default() -> Self {
+        Self::None
+    }
+}

src/metrics/mod.rs

@@ -0,0 +1,5 @@
+pub mod core;
+pub mod metrics_type;
+pub mod counter;
+mod gauge;
+mod histogram;