Compare commits

...

3 Commits

Author SHA1 Message Date
deployer3000 8d7dea30e9 Merge pull request 'rc' (#26) from rc into master 2025-04-29 14:28:16 +03:00
Vladislav Drozdov 4b1a136e1e Merge pull request 'device19 support + load balance' (#25) from feature/135 into rc
test-org/integration-module/pipeline/pr-master Build succeeded
Reviewed-on: http://git.enode/deployer3000/integration-module/pulls/25
Reviewed-by: DmitriyA <faleo1999@mail.ru>
2025-04-29 14:23:15 +03:00
prplV f71f38c666 device19 support + load balance
test-org/integration-module/pipeline/pr-rc This commit looks good Details
2025-04-29 06:24:23 -04:00
2 changed files with 4 additions and 13 deletions

View File

@ -61,10 +61,6 @@ pub async fn get_metrics_from_monitoring(duration: usize, delay: usize) -> anyho
warn!("Session dropped, creating new ...");
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
}
}

View File

@ -376,7 +376,7 @@ pub mod enode_monitoring {
impl Default for Query {
fn default() -> Self {
Self {
id : vec!["/measures/device$18".to_owned()],
id : vec!["/measures/device$18".to_owned(), "/measures/device$19".to_owned()],
data : Data::default(),
post_query : "links".to_owned(),
enable_actions : false,
@ -476,14 +476,9 @@ pub mod enode_monitoring {
pub fn get_chunk_size(total_measures: usize) -> usize {
match total_measures {
0..=144 => total_measures,
145..=288 => 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,
0..=432 => total_measures,
433..=1008 => total_measures / 2,
_ => total_measures / 4,
}
}