deployer3000
/
integration-module
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 12 Wiki Activity

add config delay #41

Merged
VladislavD merged 1 commits from feature/device-out into rc 2025-06-06 16:01:40 +03:00
Conversation 0 Commits 1 Files Changed 3
3 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
.env.example
View File

@ -30,4 +30,7 @@ ENODE_TARGET_DEVICES = "18, 19"
IM_LOG_INFO = "INFO" IM_LOG_INFO = "INFO"
# IM configuration for setting up API connetion # IM configuration for setting up API connetion
# timeout (in secs). Default value - 10 # timeout (in secs). Default value - 10
IM_CONNECTION_TIMEOUT = "10" IM_CONNECTION_TIMEOUT = "10"
# IM configuration for delay of requests
# delay (in secs). Default value - 5
IM_REQUEST_DELAY = "20"

2
crates/api-grub/Cargo.toml
View File

@ -1,6 +1,6 @@
[package] [package]
name = "api-grub" name = "api-grub"
version = "1.0.11" version = "1.0.15"
edition = "2021" edition = "2021"
authors = ["Vladislav Drozdov <maseeeeeeeed@gmail.com>"] authors = ["Vladislav Drozdov <maseeeeeeeed@gmail.com>"]
description = "API poller for ZVKS project" description = "API poller for ZVKS project"

8
crates/api-grub/src/main.rs
View File

@ -36,10 +36,16 @@ async fn main() -> Result<()>{
}, },
} }
}); });
let request_delay = std::env::var("IM_REQUEST_DELAY")
.unwrap_or_else(|_| String::from("5"))
.parse::<u32>()
.unwrap_or_else(|_| {
warn!("No delay was set, setting up as 5 secs ..."); 5
});
let event_grub = tokio::spawn(async move { let event_grub = tokio::spawn(async move {
// GRAB USING eNODE.MONITORING API GATEWAY // GRAB USING eNODE.MONITORING API GATEWAY
if std::env::var("ENODE_MONITORING_IP").is_ok() { if std::env::var("ENODE_MONITORING_IP").is_ok() {
match get_metrics_from_monitoring(0, 5).await { match get_metrics_from_monitoring(0, request_delay as usize).await {
Ok(_) => info!("Grabing (eNODE.Monitoring) task de-initialized"), Ok(_) => info!("Grabing (eNODE.Monitoring) task de-initialized"),
Err(er) => error!("Grabing task returned an error : {}", er), Err(er) => error!("Grabing task returned an error : {}", er),
} }