tyler
/
proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/bin/proxmox-backup-proxy.rs: gather datastore usage stats

This commit is contained in:
Dietmar Maurer 2020-05-25 16:00:03 +02:00
parent dda246403c
commit d0833a70f7
1 changed files with 28 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/bin/proxmox-backup-proxy.rs
View File

@ -603,7 +603,7 @@ async fn run_stat_generator() {
async fn generate_host_stats() { async fn generate_host_stats() {
use proxmox::sys::linux::procfs::{ use proxmox::sys::linux::procfs::{
read_meminfo, read_proc_stat, read_proc_net_dev, read_loadavg}; read_meminfo, read_proc_stat, read_proc_net_dev, read_loadavg};
use proxmox_backup::rrd; use proxmox_backup::{ rrd, config::datastore };
proxmox_backup::tools::runtime::block_in_place(move || { proxmox_backup::tools::runtime::block_in_place(move || {
@ -688,6 +688,33 @@ async fn generate_host_stats() {
} }
} }
match datastore::config() {
Ok((config, _)) => {
let datastore_list: Vec<datastore::DataStoreConfig> =
config.convert_to_typed_array("datastore").unwrap_or(Vec::new());
for config in datastore_list {
match disk_usage(std::path::Path::new(&config.path)) {
Ok((total, used, _avail)) => {
let rrd_key = format!("datastore/{}", config.name);
if let Err(err) = rrd::update_value(&rrd_key, total as f64, rrd::DST::Gauge) {
eprintln!("rrd::update_value '{}' failed - {}", rrd_key, err);
}
if let Err(err) = rrd::update_value(&rrd_key, used as f64, rrd::DST::Gauge) {
eprintln!("rrd::update_value '{}' failed - {}", rrd_key, err);
}
}
Err(err) => {
eprintln!("read disk_usage on {:?} failed - {}", config.path, err);
}
}
}
}
Err(err) => {
eprintln!("read datastore config failed - {}", err);
}
}
}); });
} }