diff --git a/validator/src/validator/health_check/mod.rs b/validator/src/validator/health_check/mod.rs index 5b82758500..0e820b509e 100644 --- a/validator/src/validator/health_check/mod.rs +++ b/validator/src/validator/health_check/mod.rs @@ -1,5 +1,5 @@ use crate::validator::config; -use log::debug; +use log::{debug, trace}; use std::time::Duration; pub(crate) struct HealthChecker { @@ -15,10 +15,14 @@ impl HealthChecker { } } - pub fn run(self) { + pub async fn run(self) { debug!( "healthcheck run. will use directory at: {:?} and run every {:?}", self.directory_server, self.interval, - ) + ); + loop { + tokio::time::delay_for(self.interval).await; + trace!("going to perform a healthcheck!"); + } } } diff --git a/validator/src/validator/mod.rs b/validator/src/validator/mod.rs index d61659f454..b813c2a3fd 100644 --- a/validator/src/validator/mod.rs +++ b/validator/src/validator/mod.rs @@ -1,6 +1,7 @@ use crate::validator::config::Config; use crate::validator::health_check::HealthChecker; use log::debug; +use tokio::runtime::Runtime; pub mod config; mod health_check; @@ -20,6 +21,11 @@ impl Validator { pub fn start(self) { debug!("validator run"); - self.heath_check.run() + + let mut rt = Runtime::new().unwrap(); + + let health_check_future = self.heath_check.run(); + + rt.block_on(health_check_future); } }