diff --git a/examples/validate_ceph_cluster_health/src/main.rs b/examples/validate_ceph_cluster_health/src/main.rs index 21383a8..a7b8f57 100644 --- a/examples/validate_ceph_cluster_health/src/main.rs +++ b/examples/validate_ceph_cluster_health/src/main.rs @@ -1,4 +1,8 @@ -use harmony::{inventory::Inventory, modules::storage::ceph::ceph_validate_health_score::CephVerifyClusterHealth, topology::K8sAnywhereTopology}; +use harmony::{ + inventory::Inventory, + modules::storage::ceph::ceph_validate_health_score::CephVerifyClusterHealth, + topology::K8sAnywhereTopology, +}; #[tokio::main] async fn main() { diff --git a/harmony/src/modules/storage/ceph/ceph_validate_health_score.rs b/harmony/src/modules/storage/ceph/ceph_validate_health_score.rs index d28a488..2f7f87c 100644 --- a/harmony/src/modules/storage/ceph/ceph_validate_health_score.rs +++ b/harmony/src/modules/storage/ceph/ceph_validate_health_score.rs @@ -49,7 +49,7 @@ impl Interpret for CephVerifyClusterHealthInterpret } fn get_name(&self) -> InterpretName { - InterpretName::CephClusterHealth + InterpretName::CephClusterHealth } fn get_version(&self) -> Version { @@ -123,8 +123,14 @@ impl CephVerifyClusterHealthInterpret { .await?; if health.contains("HEALTH_OK") { - return Ok(Outcome::success("Ceph Cluster in healthy state".to_string())) + return Ok(Outcome::success( + "Ceph Cluster in healthy state".to_string(), + )); } else { - Err(InterpretError::new(format!("Ceph cluster unhealthy {}", health)))} + Err(InterpretError::new(format!( + "Ceph cluster unhealthy {}", + health + ))) + } } }