use proxmox::{http_err, identity, list_subdirs_api_method, sortable};
use crate::api2::types::*;
+use crate::api2::node::rrd::create_value_from_rrd;
use crate::backup::*;
use crate::config::datastore;
use crate::config::cached_user_info::CachedUserInfo;
_param: Value,
) -> Result<Value, Error> {
- let rrd_dir = format!("datastore/{}", store);
-
- crate::rrd::extract_data(
- &rrd_dir,
+ create_value_from_rrd(
+ &format!("datastore/{}", store),
&[
"total", "used",
"read_ios", "read_bytes",
mod journal;
mod services;
mod status;
-mod rrd;
+pub(crate) mod rrd;
pub mod disks;
pub const SUBDIRS: SubdirMap = &[
use anyhow::Error;
-use serde_json::Value;
+use serde_json::{Value, json};
use proxmox::api::{api, Router};
use crate::api2::types::*;
+use crate::tools::epoch_now_f64;
+use crate::rrd::{extract_cached_data, RRD_DATA_ENTRIES};
+
+pub fn create_value_from_rrd(
+ basedir: &str,
+ list: &[&str],
+ timeframe: RRDTimeFrameResolution,
+ cf: RRDMode,
+) -> Result<Value, Error> {
+
+ let mut result = Vec::new();
+ let now = epoch_now_f64()?;
+
+ for name in list {
+ let (start, reso, list) = match extract_cached_data(basedir, name, now, timeframe, cf) {
+ Some(result) => result,
+ None => continue,
+ };
+
+ let mut t = start;
+ for index in 0..RRD_DATA_ENTRIES {
+ if result.len() <= index {
+ if let Some(value) = list[index] {
+ result.push(json!({ "time": t, *name: value }));
+ } else {
+ result.push(json!({ "time": t }));
+ }
+ } else {
+ if let Some(value) = list[index] {
+ result[index][name] = value.into();
+ }
+ }
+ t += reso;
+ }
+ }
+
+ Ok(result.into())
+}
#[api(
input: {
_param: Value,
) -> Result<Value, Error> {
- crate::rrd::extract_data(
+ create_value_from_rrd(
"host",
&[
"cpu", "iowait",
use anyhow::{format_err, Error};
use lazy_static::lazy_static;
-use serde_json::{json, Value};
use proxmox::tools::fs::{create_path, CreateOptions};
Ok((times, result))
}
-pub fn extract_data(
+pub fn extract_cached_data(
base: &str,
- items: &[&str],
+ name: &str,
+ now: f64,
timeframe: RRDTimeFrameResolution,
mode: RRDMode,
-) -> Result<Value, Error> {
-
- let now = epoch_now_f64()?;
+) -> Option<(u64, u64, Vec<Option<f64>>)> {
let map = RRD_CACHE.read().unwrap();
- let mut result = Vec::new();
-
- for name in items.iter() {
- let rrd = match map.get(&format!("{}/{}", base, name)) {
- Some(rrd) => rrd,
- None => continue,
- };
- let (start, reso, list) = rrd.extract_data(now, timeframe, mode);
- let mut t = start;
- for index in 0..RRD_DATA_ENTRIES {
- if result.len() <= index {
- if let Some(value) = list[index] {
- result.push(json!({ "time": t, *name: value }));
- } else {
- result.push(json!({ "time": t }));
- }
- } else {
- if let Some(value) = list[index] {
- result[index][name] = value.into();
- }
- }
- t += reso;
- }
+ match map.get(&format!("{}/{}", base, name)) {
+ Some(rrd) => Some(rrd.extract_data(now, timeframe, mode)),
+ None => None,
}
-
- Ok(result.into())
}