Struct engine_rocks::rocks_metrics::SimpleEngineTickerMetricsInner

pub struct SimpleEngineTickerMetricsInner {
    pub kv: LocalIntCounter,
    pub raft: LocalIntCounter,
    last_flush: Cell<u64>,
    flush_millis: u64,
}

Fields

kv: LocalIntCounter

raft: LocalIntCounter

last_flush: Cell<u64>

flush_millis: u64

Implementations

impl SimpleEngineTickerMetricsInner

pub fn from(m: &IntCounterVec) -> SimpleEngineTickerMetricsInner

pub fn flush(&self)

pub fn with_flush_duration(self, duration: Duration) -> Self

Trait Implementations

impl CounterDelegator<SimpleEngineTickerMetricsInner, GenericLocalCounter<AtomicI64>> for SimpleEngineTickerMetricsDelegator

fn get_root_metric(&self) -> &'static LocalKey<SimpleEngineTickerMetricsInner>

Get the root local metric for delegate

fn get_local<'a>(
    &self,
    root_metric: &'a SimpleEngineTickerMetricsInner
) -> &'a LocalIntCounter

Get the final counter for delegate

impl LocalMetric for SimpleEngineTickerMetricsInner

fn flush(&self)

Flush the local metrics to the global one.

impl MayFlush for SimpleEngineTickerMetricsInner

fn may_flush(&self)

Open to implementation to fill try_flush parameters

pub fn try_flush(&self, last_flush: &Cell<u64>, flush_interval_millis: u64)

If the LocalMetric is already flushed in last flush_interval_sec seconds, then do nothing, else flush and update last flush time.