Compare commits

..

No commits in common. "8d7dea30e9995454866216d9dc0b4fdee7c173fe" and "2e8fd1d17dfb38eb5e798ccb29c5ccc2e998c82d" have entirely different histories.

2 changed files with 13 additions and 4 deletions

View File

@ -61,6 +61,10 @@ pub async fn get_metrics_from_monitoring(duration: usize, delay: usize) -> anyho
warn!("Session dropped, creating new ..."); warn!("Session dropped, creating new ...");
break 'inner; break 'inner;
} }
// if let Err(_) = a.get_measure_info(vec.clone()).await {
// warn!("Session dropped, creating new ...");
// break 'inner;
// }
tokio::time::sleep(tokio::time::Duration::from_secs(delay as u64)).await tokio::time::sleep(tokio::time::Duration::from_secs(delay as u64)).await
} }
} }

View File

@ -376,7 +376,7 @@ pub mod enode_monitoring {
impl Default for Query { impl Default for Query {
fn default() -> Self { fn default() -> Self {
Self { Self {
id : vec!["/measures/device$18".to_owned(), "/measures/device$19".to_owned()], id : vec!["/measures/device$18".to_owned()],
data : Data::default(), data : Data::default(),
post_query : "links".to_owned(), post_query : "links".to_owned(),
enable_actions : false, enable_actions : false,
@ -476,9 +476,14 @@ pub mod enode_monitoring {
pub fn get_chunk_size(total_measures: usize) -> usize { pub fn get_chunk_size(total_measures: usize) -> usize {
match total_measures { match total_measures {
0..=432 => total_measures, 0..=144 => total_measures,
433..=1008 => total_measures / 2, 145..=288 => total_measures / 4,
_ => total_measures / 4, 289..=432 => total_measures / 5,
433..=576 => total_measures / 6,
577..=720 => total_measures / 7,
721..=864 => total_measures / 8,
865..=1008 => total_measures / 9,
_ => total_measures / 10,
} }
} }