chore: cargo fmt

Author: drahnr

src/error.rs

@@ -15,7 +15,11 @@ pub enum PyroscopeError {
     AdHoc(String),
 
     #[error("{msg}: {source:?}")]
-    Compat{ msg: String, #[source] source: Box<dyn std::error::Error + Send + Sync + 'static> },
+    Compat {
+        msg: String,
+        #[source]
+        source: Box<dyn std::error::Error + Send + Sync + 'static>,
+    },
 
     #[error(transparent)]
     Reqwest(#[from] reqwest::Error),
@@ -37,7 +41,10 @@ impl PyroscopeError {
     }
 
     /// Create a new instance of PyroscopeError with source
-    pub fn new_with_source<E>(msg: &str, source: E) -> Self where E: std::error::Error + Send + Sync + 'static {
+    pub fn new_with_source<E>(msg: &str, source: E) -> Self
+    where
+        E: std::error::Error + Send + Sync + 'static,
+    {
         PyroscopeError::Compat {
             msg: msg.to_string(),
             source: Box::new(source),

src/pyroscope.rs

@@ -16,7 +16,6 @@ use crate::{
 
 const LOG_TAG: &str = "Pyroscope::Agent";
 
-
 /// Pyroscope Agent Configuration. This is the configuration that is passed to the agent.
 /// # Example
 /// ```
@@ -287,7 +286,10 @@ impl Drop for PyroscopeAgent {
         // Stop the SessionManager
         match self.session_manager.push(SessionSignal::Kill) {
             Ok(_) => log::trace!(target: LOG_TAG, "Sent kill signal to SessionManager"),
-            Err(_) => log::error!(target: LOG_TAG, "Error sending kill signal to SessionManager"),
+            Err(_) => log::error!(
+                target: LOG_TAG,
+                "Error sending kill signal to SessionManager"
+            ),
         }
 
         if let Some(handle) = self.session_manager.handle.take() {
@@ -306,7 +308,7 @@ impl Drop for PyroscopeAgent {
             }
         }
 
-        log::debug!(target:  LOG_TAG, "Agent Dropped");
+        log::debug!(target: LOG_TAG, "Agent Dropped");
     }
 }
 

src/session.rs

@@ -124,7 +124,12 @@ impl Session {
     /// session.send()?;
     /// ```
     pub fn send(self) -> Result<()> {
-        log::info!(target: LOG_TAG, "Sending Session: {} - {}", self.from, self.until);
+        log::info!(
+            target: LOG_TAG,
+            "Sending Session: {} - {}",
+            self.from,
+            self.until
+        );
 
         // Check if the report is empty
         if self.report.is_empty() {

src/timer/kqueue.rs

@@ -58,7 +58,6 @@ impl Timer {
                     return Ok(());
                 }
 
-
                 // Get current time
                 let from = get_time_range(0)?.from;
 

src/timer/mod.rs

@@ -4,7 +4,6 @@
 // https://www.apache.org/licenses/LICENSE-2.0>. This file may not be copied, modified, or distributed
 // except according to those terms.
 
-
 /// A signal sent to the timer.
 ///
 /// Either schedules another wake-up, or asks
@@ -26,12 +25,18 @@ impl std::fmt::Display for TimerSignal {
     }
 }
 // Possibly: ios, netbsd, openbsd, freebsd
-#[cfg(target_os = "macos")] pub mod kqueue;
-#[cfg(target_os = "macos")] pub use kqueue::Timer;
+#[cfg(target_os = "macos")]
+pub mod kqueue;
+#[cfg(target_os = "macos")]
+pub use kqueue::Timer;
 
 // Possibly: android
-#[cfg(target_os = "linux")] pub mod epoll;
-#[cfg(target_os = "linux")] pub use epoll::Timer;
+#[cfg(target_os = "linux")]
+pub mod epoll;
+#[cfg(target_os = "linux")]
+pub use epoll::Timer;
 
-#[cfg(not(any(target_os = "linux", target_os = "macos")))] pub mod sleep;
-#[cfg(not(any(target_os = "linux", target_os = "macos")))] pub use sleep::Timer;
+#[cfg(not(any(target_os = "linux", target_os = "macos")))]
+pub mod sleep;
+#[cfg(not(any(target_os = "linux", target_os = "macos")))]
+pub use sleep::Timer;

tests/session.rs

@@ -2,10 +2,7 @@ use pyroscope::{
     pyroscope::PyroscopeConfig,
     session::{Session, SessionManager, SessionSignal},
 };
-use std::{
-    collections::HashMap,
-    time::Duration,
-};
+use std::{collections::HashMap, time::Duration};
 
 #[test]
 fn test_session_manager_new() {

tests/timer.rs

@@ -1,5 +1,5 @@
-use pyroscope::timer::{TimerSignal, Timer};
 use assert_matches::assert_matches;
+use pyroscope::timer::{Timer, TimerSignal};
 
 #[test]
 fn test_timer() {