pub mod cpuload;
pub mod meminfo;
pub mod report;
#[cfg(feature = "enable_ipcon")]
pub mod ipcon;
use serde::{de::DeserializeOwned, Serialize};
#[allow(unused)]
use std::sync::mpsc::{Receiver, Sender};
use std::sync::Arc;
use std::{error::Error, fmt::Display};
#[allow(unused)]
use tracing::{debug, error, info, warn};
use error_stack::Result;
#[derive(Debug)]
pub enum InfomgrError {
IOError,
InvalidData,
#[cfg(feature = "enable_ipcon")]
IpconError,
Unexpected,
}
impl Display for InfomgrError {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let err_str = match self {
InfomgrError::IOError => "IO error",
InfomgrError::InvalidData => "Invalid data",
#[cfg(feature = "enable_ipcon")]
InfomgrError::IpconError => "Ipcon error",
_ => "Unexpected data",
};
write!(f, "{}", err_str)
}
}
impl Error for InfomgrError {}
pub trait InfoCon {
fn sender<T>(&mut self, source: Arc<String>, receiver: Receiver<T>) -> Result<(), InfomgrError>
where
T: 'static + Serialize + Send;
fn receiver<T>(
&mut self,
source: Arc<String>,
sender: Sender<Option<T>>,
) -> Result<(), InfomgrError>
where
T: 'static + DeserializeOwned + Send;
}