epoch-db 0.2.9

An intelligent, persistent, and concurrent key-value store for Rust, designed to manage data with a lifecycle through frequency tracking and TTL.
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

//! This `metric_handler` module contains the core logic and struct for the
//! database transaction method metric handling system.
//!
//! Since sled transaction retries the transaction multiple times if
//! failed, it will keep updating the metric which is fixed by the logic of this
//! module

use crate::metrics::Metrics;

pub struct GuardMetricChanged {
    pub keys_total_changed: i64,
    pub ttl_keys_total_changed: i64,
    pub set_operation_total: u64,
    pub rm_operation_total: u64,
    pub inc_freq_operation_total: u64,
    pub get_operation_total: u64
}

impl GuardMetricChanged {
    pub fn inc_all_metrics(&self) {
        let i = self.keys_total_changed;

        if i > 0 {
            Metrics::inc_amount_keys_total("data", i.unsigned_abs());
            Metrics::inc_amount_keys_total("meta", i.unsigned_abs());
        } else {
            Metrics::dec_amount_keys_total("data", i.unsigned_abs());
            Metrics::dec_amount_keys_total("meta", i.unsigned_abs());
        }

        let i = self.ttl_keys_total_changed;

        if i > 0 {
            Metrics::inc_amount_keys_total("ttl", i.unsigned_abs());
        } else {
            Metrics::dec_amount_keys_total("ttl", i.unsigned_abs());
        }

        Metrics::increment_amount_operations("set", self.set_operation_total);
        Metrics::increment_amount_operations("rm", self.rm_operation_total);
        Metrics::increment_amount_operations("increment_frequency", self.inc_freq_operation_total);
        Metrics::increment_amount_operations("get", self.get_operation_total);
    }
}