Fix metrics send

Author: the2pizza

src/bin/agent/core/service.rs

@@ -321,7 +321,7 @@ pub async fn run(settings: AgentSettings) -> Result<()> {
                     tokio::select! {
                         _ = sleep(Duration::from_secs(settings.agent.metrics_interval)) => {
                             match agent.send_metrics(&carbon_addr).await {
-                                Ok(_) => log::debug!("✅ Sent metrics to {}", carbon_addr),
+                                Ok(_) => {},
                                 Err(e) => log::error!("❌ Failed to send metrics: {}", e),
                             }
                         },
@@ -345,7 +345,7 @@ pub async fn run(settings: AgentSettings) -> Result<()> {
                     tokio::select! {
                         _ = sleep(Duration::from_secs(settings.agent.metrics_hb_interval)) => {
                             match agent.send_hb_metric(&carbon_addr).await {
-                                Ok(_) => log::debug!("✅ Sent heartbeat to {}", carbon_addr),
+                                Ok(_) => {},
                                 Err(e) => log::error!("❌ Failed to send heartbeat: {}", e),
                             }
                         },

src/metrics/metrics.rs

@@ -44,17 +44,13 @@ impl<T: Default> Default for Metric<T> {
 
 impl<T: fmt::Display> fmt::Display for Metric<T> {
     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
-        write!(
-            f,
-            "Metric {{ path: {}, value: {},  timestamp: {} }}",
-            self.metric, self.value, self.timestamp
-        )
+        write!(f, "{} {} {}", self.metric, self.value, self.timestamp)
     }
 }
 
 impl<T: std::fmt::Display + std::fmt::Debug> Metric<T> {
     pub async fn send(&self, server: &str) -> Result<(), io::Error> {
-        let metric_string = self.to_string();
+        let metric_string = format!("{}\n", self.to_string());
 
         log::debug!("Sending carbon metric string: {}", metric_string);