rinq 0.1.0

Type-safe, zero-cost LINQ-inspired query engine for Rust — filter, sort, aggregate, window analytics, parallel execution, and statistical extensions.
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

//shared/metrics/collector.rs
// メトリクス収集器
// 2025/7/8

use parking_lot::RwLock;
use std::collections::HashMap;
use std::sync::Arc;

/// Metrics collector for tracking application metrics
#[derive(Clone)]
pub struct MetricsCollector {
    metrics: Arc<RwLock<HashMap<String, u64>>>,
}

impl MetricsCollector {
    pub fn new() -> Self {
        Self {
            metrics: Arc::new(RwLock::new(HashMap::new())),
        }
    }

    pub fn increment(&self, key: &str) {
        let mut metrics = self.metrics.write();
        *metrics.entry(key.to_string()).or_insert(0) += 1;
    }

    pub fn get(&self, key: &str) -> Option<u64> {
        let metrics = self.metrics.read();
        metrics.get(key).copied()
    }

    pub fn record_query_execution(&self, operation_name: &str, _duration: std::time::Duration) {
        self.increment(&format!("query_{}", operation_name));
    }
}

impl Default for MetricsCollector {
    fn default() -> Self {
        Self::new()
    }
}