pub async fn monitor_delay(self, probe: u64) {
        let mut graphite = self.graphite.map(Graphite::new);
        let interval = Duration::from_secs(probe);

        test_all(&self).await;

        let mut interval = interval_at(Instant::now() + interval, interval);
        loop {
            interval.tick().await;
            test_all(&self).await;
            if let Some(ref mut graphite) = graphite {
                match send_metrics(&self, graphite).await {
                    Ok(_) => debug!("metrics sent"),
                    Err(e) => warn!("fail to send metrics {:?}", e),
                }
            }
        }
    }
/// Start monitoring delays.
/// Returned Future won't return unless error on timer.
Start monitoring delays.
Returned Future won't return unless error on timer.
Start monitoring delays . Returned Future won ' t return unless error on timer .
pub async fn monitor_delay(self, probe: u64) {
        let mut graphite = self.graphite.map(Graphite::new);
        let interval = Duration::from_secs(probe);
        test_all(&self).await;
        let mut interval = interval_at(Instant::now() + interval, interval);
        loop {
            interval.tick().await;
            test_all(&self).await;
            if let Some(ref mut graphite) = graphite {
                match send_metrics(&self, graphite).await {
                    Ok(_) => debug!("metrics sent"),
                    Err(e) => warn!("fail to send metrics {:?}", e),
                }
            }
        }
    }
pub async fn monitor_delay ( self , probe : u64 ) { let mut graphite = self . graphite . map ( Graphite :: new ) ; let interval = Duration :: from_secs ( probe ) ; test_all ( & self ) . await ; let mut interval = interval_at ( Instant :: now ( ) + interval , interval ) ; loop { interval . tick ( ) . await ; test_all ( & self ) . await ; if let Some ( ref mut graphite ) = graphite { match send_metrics ( & self , graphite ) . await { Ok ( _ ) => debug ! ( " " ) , Err ( e ) => warn ! ( " " e ) , } } } }
Start monitoring delays.
Start monitoring delays .
self
probe
u64
self
probe
u64