Compare commits
2 Commits
c8bf5e7cd9
...
5de11c05ff
| Author | SHA1 | Date |
|---|---|---|
|
|
5de11c05ff | |
|
|
0cf7565dff |
|
|
@ -31,3 +31,6 @@ IM_LOG_INFO = "INFO"
|
|||
# IM configuration for setting up API connetion
|
||||
# timeout (in secs). Default value - 10
|
||||
IM_CONNECTION_TIMEOUT = "10"
|
||||
# IM configuration for delay of requests
|
||||
# delay (in secs). Default value - 5
|
||||
IM_REQUEST_DELAY = "20"
|
||||
|
|
@ -1,6 +1,6 @@
|
|||
[package]
|
||||
name = "api-grub"
|
||||
version = "1.0.11"
|
||||
version = "1.0.15"
|
||||
edition = "2021"
|
||||
authors = ["Vladislav Drozdov <maseeeeeeeed@gmail.com>"]
|
||||
description = "API poller for ZVKS project"
|
||||
|
|
|
|||
|
|
@ -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 {
|
||||
// GRAB USING eNODE.MONITORING API GATEWAY
|
||||
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"),
|
||||
Err(er) => error!("Grabing task returned an error : {}", er),
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue