niko/oxkerclone
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: rename scheduler to heartbeat

Browse Source
This commit is contained in:
Jack Wills
2024-11-15 16:36:32 +00:00
parent 76ccf7c006
commit 68a6551ed0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/docker_data/mod.rs
+2 -2
View File
@@ -411,7 +411,7 @@ impl DockerData {
} }
/// Send an update message every x ms, where x is the args.docker_interval /// Send an update message every x ms, where x is the args.docker_interval
fn scheduler(args: &CliArgs, docker_tx: Sender<DockerMessage>) { fn heartbeat(args: &CliArgs, docker_tx: Sender<DockerMessage>) {
let update_duration = std::time::Duration::from_millis(u64::from(args.docker_interval)); let update_duration = std::time::Duration::from_millis(u64::from(args.docker_interval));
let mut now = std::time::Instant::now(); let mut now = std::time::Instant::now();
tokio::spawn(async move { tokio::spawn(async move {
@@ -445,7 +445,7 @@ impl DockerData {
spawns: Arc::new(Mutex::new(HashMap::new())), spawns: Arc::new(Mutex::new(HashMap::new())),
}; };
inner.initialise_container_data().await; inner.initialise_container_data().await;
Self::scheduler(&args, docker_tx); Self::heartbeat(&args, docker_tx);
inner.message_handler().await; inner.message_handler().await;
} }
} }