Struct engine_rocks::rocks_metrics::EngineTickerMetricsInner

pub struct EngineTickerMetricsInner {
    pub kv: EngineTickerMetrics2Inner,
    pub raft: EngineTickerMetrics2Inner,
    last_flush: Cell<u64>,
    flush_millis: u64,
}

Fields

kv: EngineTickerMetrics2Inner

raft: EngineTickerMetrics2Inner

last_flush: Cell<u64>

flush_millis: u64

Implementations

impl EngineTickerMetricsInner

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

pub fn flush(&self)

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

Trait Implementations

impl CounterDelegator<EngineTickerMetricsInner, GenericLocalCounter<AtomicI64>> for EngineTickerMetrics2Delegator

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

Get the root local metric for delegate

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

Get the final counter for delegate

impl LocalMetric for EngineTickerMetricsInner

fn flush(&self)

Flush the local metrics to the global one.

impl MayFlush for EngineTickerMetricsInner

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.