slatedb 0.12.1

A cloud native embedded storage engine built on object storage.
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

use slatedb_common::metrics::{CounterFn, MetricsRecorderHelper};
use std::sync::Arc;

macro_rules! gc_stat_name {
    ($suffix:expr) => {
        concat!("slatedb.gc.", $suffix)
    };
}

pub const DELETED_COUNT: &str = gc_stat_name!("deleted_count");
pub const GC_COUNT: &str = gc_stat_name!("count");

/// Stats for the garbage collector.
pub struct GcStats {
    pub gc_manifest_count: Arc<dyn CounterFn>,
    pub gc_wal_count: Arc<dyn CounterFn>,
    pub gc_compacted_count: Arc<dyn CounterFn>,
    pub gc_compactions_count: Arc<dyn CounterFn>,
    pub gc_count: Arc<dyn CounterFn>,
}

impl GcStats {
    pub(crate) fn new(recorder: &MetricsRecorderHelper) -> Self {
        Self {
            gc_manifest_count: recorder
                .counter(DELETED_COUNT)
                .labels(&[("resource", "manifest")])
                .register(),
            gc_wal_count: recorder
                .counter(DELETED_COUNT)
                .labels(&[("resource", "wal")])
                .register(),
            gc_compacted_count: recorder
                .counter(DELETED_COUNT)
                .labels(&[("resource", "compacted")])
                .register(),
            gc_compactions_count: recorder
                .counter(DELETED_COUNT)
                .labels(&[("resource", "compactions")])
                .register(),
            gc_count: recorder.counter(GC_COUNT).register(),
        }
    }
}