Add scaphandre cpu usage percentage

hubblo-org · Mar 11, 2023 · e901c21 · e901c21
1 parent c3b57c8
commit e901c21
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/exporters/elastic.rs b/src/exporters/elastic.rs
@@ -121,6 +121,7 @@ const ES_INDEX_NAME: &str = "scaphandre";
 #[derive(Debug, Serialize, Deserialize, PartialEq)]
 pub struct ScaphandreData {
     pub scaphandre_version: String,
+    pub scaphandre_cpu_usage_percentage: Option<u32>,
 }
 
 impl ElasticExporter {
@@ -151,6 +152,7 @@ impl ElasticExporter {
                 ))
                 .body(ScaphandreData {
                     scaphandre_version: get_scaphandre_version(),
+                    scaphandre_cpu_usage_percentage: self.get_scaphandre_cpu_usage_percentage(),
                 })
                 .send()
                 .await
@@ -166,6 +168,14 @@ impl ElasticExporter {
         }
     }
 
+    fn get_scaphandre_cpu_usage_percentage(&self) -> Option<u32> {
+        self.topology
+            .get_process_cpu_consumption_percentage(procfs::process::Process::myself().ok()?.pid())?
+            .value
+            .parse::<u32>()
+            .ok()
+    }
+
     async fn ensure_index(&self, client: &Elasticsearch) -> Result<(), Error> {
         let index_exist_resp = client
             .indices()