diff --git a/apps/charging-engine/src/monitoring.rs b/apps/charging-engine/src/monitoring.rs index eb3a516..336bc6b 100644 --- a/apps/charging-engine/src/monitoring.rs +++ b/apps/charging-engine/src/monitoring.rs @@ -1,3 +1,3 @@ pub mod sync; pub mod types; -pub mod monitoring; +pub mod monitoring_impl; diff --git a/apps/charging-engine/src/monitoring/monitoring_impl.rs b/apps/charging-engine/src/monitoring/monitoring_impl.rs index 7308391..f889fcc 100644 --- a/apps/charging-engine/src/monitoring/monitoring_impl.rs +++ b/apps/charging-engine/src/monitoring/monitoring_impl.rs @@ -37,13 +37,11 @@ impl crate::charging::ChargingEngine { let info: String = redis::cmd("INFO").query_async(&mut conn).await.unwrap_or_default(); for line in info.lines() { - if line.starts_with("instantaneous_ops_per_sec:") { - if let Some(rps_str) = line.split(':').nth(1) { - if let Ok(rps) = rps_str.parse::() { - return Ok(rps); - } + if line.starts_with("instantaneous_ops_per_sec:") + && let Some(rps_str) = line.split(':').nth(1) + && let Ok(rps) = rps_str.parse::() { + return Ok(rps); } - } } let total_commands = self.extract_metric(&info, "total_commands_processed");