Struct raftstore::store::worker::pd::StatsMonitor

[+] Show declaration

struct StatsMonitor<E> where
    E: KvEngine,  {
    scheduler: Scheduler<Task<E>>,
    handle: Option<JoinHandle<()>>,
    timer: Option<Sender<bool>>,
    sender: Option<Sender<ReadStats>>,
    thread_info_interval: Duration,
    qps_info_interval: Duration,
    collect_interval: Duration,
}

Fields

scheduler: Scheduler<Task<E>>

handle: Option<JoinHandle<()>>

timer: Option<Sender<bool>>

sender: Option<Sender<ReadStats>>

thread_info_interval: Duration

qps_info_interval: Duration

collect_interval: Duration

Implementations

impl<E> StatsMonitor<E> where
    E: KvEngine, [−]

pub fn new(interval: Duration, scheduler: Scheduler<Task<E>>) -> Self

pub fn start(
    &mut self,
    auto_split_controller: AutoSplitController
) -> Result<(), Error>

pub fn stop(&mut self)

pub fn get_sender(&self) -> &Option<Sender<ReadStats>>