LibreCloud/ZTerton
1
1
Fork 0
Code Issues Pull Requests Projects Releases 2 Wiki Activity

chore: add DEBUG, logs to monitor

Browse Source
This commit is contained in:
Jesús Pérez Lorenzo 2021-09-14 23:29:00 +01:00
parent 66ccd59f07
commit 07105a7d17
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main.rs
View File

@ -182,7 +182,7 @@ pub async fn run_cache_clouds() -> Result<()> {
arg_env_path=args[idx+1].to_owned(); arg_env_path=args[idx+1].to_owned();
} }
}); });
println!("Cache service on Clouds: run {} __________ {} / {} ",chrono::Utc::now().timestamp(),&arg_cfg_path,&arg_env_path); println!("Cache service on Clouds: run {} __________ {} {} ",chrono::Utc::now().timestamp(),&arg_cfg_path,&arg_env_path);
let mut cloud = Cloud::default(); let mut cloud = Cloud::default();
load_cloud_env(&mut cloud).await; load_cloud_env(&mut cloud).await;
let mut app_env = AppEnv::default(); let mut app_env = AppEnv::default();
@ -218,7 +218,7 @@ pub async fn run_check_clouds() -> Result<()> {
arg_env_path=args[idx+1].to_owned(); arg_env_path=args[idx+1].to_owned();
} }
}); });
println!("Check Cloud services: run {} __________ {} / {} ",chrono::Utc::now().timestamp(),&arg_cfg_path,&arg_env_path); println!("Check Cloud services: run {} __________ {} {} ",chrono::Utc::now().timestamp(),&arg_cfg_path,&arg_env_path);
let mut cloud = Cloud::default(); let mut cloud = Cloud::default();
load_cloud_env(&mut cloud).await; load_cloud_env(&mut cloud).await;
let mut app_env = AppEnv::default(); let mut app_env = AppEnv::default();
@ -253,7 +253,7 @@ pub async fn run_clouds_monitor() -> Result<()> {
arg_env_path=args[idx+1].to_owned(); arg_env_path=args[idx+1].to_owned();
} }
}); });
println!("Monitor Cloud: run {} __________ {} / {} ",chrono::Utc::now().timestamp(),&arg_cfg_path,&arg_env_path); println!("Monitor Cloud: run {} __________ {} {} ",chrono::Utc::now().timestamp(),&arg_cfg_path,&arg_env_path);
let mut cloud = Cloud::default(); let mut cloud = Cloud::default();
load_cloud_env(&mut cloud).await; load_cloud_env(&mut cloud).await;
let mut app_env = AppEnv::default(); let mut app_env = AppEnv::default();
@ -332,20 +332,27 @@ pub async fn main() -> BxDynResult<()> { //std::io::Result<()> {
eprintln!("Task {} no schedule defined",&it.name); eprintln!("Task {} no schedule defined",&it.name);
continue; continue;
} }
let debug=envmnt::get_isize("DEBUG",0);
let res = match it.name.as_str() { let res = match it.name.as_str() {
"monitor" => "monitor" =>
sched.add(Job::new(&it.schedule.to_owned(), move |uuid, _l| { sched.add(Job::new(&it.schedule.to_owned(), move |uuid, _l| {
if debug > 0 {
println!("Schedule {} {}: {}",&it.name,&it.schedule,uuid); println!("Schedule {} {}: {}",&it.name,&it.schedule,uuid);
}
tokio::spawn(async {run_clouds_monitor().await}); tokio::spawn(async {run_clouds_monitor().await});
})?), })?),
"check" => "check" =>
sched.add(Job::new(&it.schedule.to_owned(), move |uuid, _l| { sched.add(Job::new(&it.schedule.to_owned(), move |uuid, _l| {
if debug > 0 {
println!("Schedule {} {}: {}",&it.name,&it.schedule,uuid); println!("Schedule {} {}: {}",&it.name,&it.schedule,uuid);
}
tokio::spawn(async {run_check_clouds().await}); tokio::spawn(async {run_check_clouds().await});
})?), })?),
"cache" => "cache" =>
sched.add(Job::new(&it.schedule.to_owned(), move |uuid, _l| { sched.add(Job::new(&it.schedule.to_owned(), move |uuid, _l| {
if debug > 0 {
println!("Schedule {} {}: {}",&it.name,&it.schedule,uuid); println!("Schedule {} {}: {}",&it.name,&it.schedule,uuid);
}
tokio::spawn(async {run_cache_clouds().await}); tokio::spawn(async {run_cache_clouds().await});
})?), })?),
_ => { _ => {