feat: use health_check_interval in place of static duration

src/proxy.rs

@@ -16,7 +16,6 @@ use std::{
 use tracing::{debug, error, info};
 
 pub fn http_health(conf: Arc<Config>, sender: SendTargets) {
-    let duration = Duration::from_secs(5);
     let health_client = reqwest::blocking::Client::builder()
         .timeout(Duration::from_secs(1))
         .build()
@@ -65,7 +64,7 @@ pub fn http_health(conf: Arc<Config>, sender: SendTargets) {
             }
             debug!("[HTTP] Sending targets to channel");
             sender.send(healthy_targets).unwrap();
-            thread::sleep(duration);
+            thread::sleep(conf.health_check_interval());
         }
     } else {
         info!("No targets configured, unable to health check.");
@@ -74,8 +73,6 @@ pub fn http_health(conf: Arc<Config>, sender: SendTargets) {
 
 /// Run health checks against the configured TCP targets.
 pub fn tcp_health(conf: Arc<Config>, sender: SendTargets) {
-    let duration = Duration::from_secs(5);
-
     if let Some(targets) = &conf.targets {
         info!("Starting TCP health checks");
         loop {
@@ -111,7 +108,7 @@ pub fn tcp_health(conf: Arc<Config>, sender: SendTargets) {
             }
             debug!("Sending targets to channel");
             sender.send(healthy_targets).unwrap();
-            thread::sleep(duration);
+            thread::sleep(conf.health_check_interval());
         }
     } else {
         info!("No targets configured, unable to health check.");

tests/lb.rs

@@ -2,7 +2,7 @@ use assert_cmd::prelude::*;
 use gruglb;
 use std::process::Command;
 use std::sync::{Arc, Mutex};
-use std::{thread, time::Duration};
+use std::thread;
 
 mod common;
 
@@ -41,11 +41,11 @@ fn register_healthy_targets() {
     let test_config = common::test_targets_config();
 
     let (send, recv) = common::get_send_recv();
-    let lb = gruglb::lb::new(test_config);
+    let lb = gruglb::lb::new(test_config.clone());
     let _ = lb.run(send, recv);
 
     // Wait for some set duration so that the health checks are conducted.
-    thread::sleep(Duration::from_secs(10));
+    thread::sleep(test_config.health_check_interval());
 
     let tcp_healthy_backends = lb
         .current_healthy_targets