robin/prometheus-edge-trigger
1
0
Fork 0
mirror of https://codeberg.org/icewind/prometheus-edge-trigger.git synced 2026-06-03 18:24:10 +02:00
Code Issues Projects Releases Packages Wiki Activity

bumb dependencies

Browse source
This commit is contained in:
Robin Appelman 2022-06-07 20:20:03 +02:00
commit 5a635578bb
4 changed files with 311 additions and 494 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/main.rs
View file

@ -2,7 +2,7 @@ use crate::config::Config;
use crate::trigger::TriggerManager;
use main_error::MainError;
use tokio::fs::File;
use tokio::prelude::*;
use tokio::io::AsyncReadExt;
mod config;
mod mdns;

12
src/trigger.rs
View file

@ -10,7 +10,7 @@ use reqwest::Client;
use rumqttc::{AsyncClient, ClientError, Event, MqttOptions, Outgoing, QoS};
use std::collections::HashMap;
use std::time::{Duration, SystemTime};
use tokio::time::delay_for;
use tokio::time::sleep;
pub struct TriggerManager {
http_client: Client,
@ -81,7 +81,7 @@ impl TriggerManager {
trigger.name, elapsed, wait
);
let wait_delay = Duration::from_secs(wait);
delay_for(wait_delay).await;
sleep(wait_delay).await;
// verify that the previously found edge is still the most recent
match self.get_edge(&trigger.condition, delay).await {
@ -96,11 +96,11 @@ impl TriggerManager {
{
error!("[{}]: {}", trigger.name, e);
}
delay_for(delay_duration).await;
sleep(delay_duration).await;
}
Err(e) => {
error!("[{}]: {}", trigger.name, e);
delay_for(error_delay).await;
sleep(error_delay).await;
}
_ => {
info!("[{}] Edge no longer valid", trigger.name);
@ -112,11 +112,11 @@ impl TriggerManager {
"[{}] No edge found, waiting {}s before looking for new edge",
trigger.name, delay
);
delay_for(delay_duration).await;
sleep(delay_duration).await;
}
Err(e) => {
error!("[{}]: {}", trigger.name, e);
delay_for(error_delay).await;
sleep(error_delay).await;
}
}
}