Struct tikv::server::metrics::prometheus_static_scope_8::SnapTaskCounterVecInner

pub struct SnapTaskCounterVecInner {
    pub send: LocalIntCounter,
    pub recv: LocalIntCounter,
    last_flush: Cell<u64>,
    flush_millis: u64,
}

Fields

send: LocalIntCounter

recv: LocalIntCounter

last_flush: Cell<u64>

flush_millis: u64

Implementations

impl SnapTaskCounterVecInner

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

pub fn flush(&self)

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

Trait Implementations

impl CounterDelegator<SnapTaskCounterVecInner, GenericLocalCounter<AtomicI64>> for SnapTaskCounterVecDelegator

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

Get the root local metric for delegate

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

Get the final counter for delegate

impl LocalMetric for SnapTaskCounterVecInner

fn flush(&self)

Flush the local metrics to the global one.

impl MayFlush for SnapTaskCounterVecInner

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.