fix(procmgr): satisfy Windows CI rustfmt and clippy checks

Apply rustfmt to the manager split and remove Windows-only dead code
that failed clippy with -D warnings.

Author: jose-manuel-almaza

pkg/procmgr/rust/src/config.rs

@@ -3,7 +3,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2026-present Datadog, Inc.
 
-
 use crate::platform;
 use anyhow::{Context, Result};
 use log::{debug, info, warn};

pkg/procmgr/rust/src/manager/mod.rs

@@ -11,18 +11,16 @@ mod supervisor;
 
 use supervisor::RuntimeHandles;
 
-use crate::config::ProcessDefinition;
 use crate::process::ManagedProcess;
 use anyhow::Result;
 use log::warn;
-use std::sync::Arc;
 use tokio::sync::mpsc;
 use tonic::Status;
 
 pub use process_manager::ProcessManager;
 pub use supervisor::Supervisor;
 
-#[cfg(test)]
+#[cfg(all(test, unix))]
 pub(crate) use supervisor::spawn_command_loop_for_tests;
 
 pub(crate) struct ExitEvent {
@@ -125,10 +123,14 @@ fn spawn_watcher(proc: &mut ManagedProcess, tx: mpsc::Sender<ExitEvent>) {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::config::{ConfigLoader, MutableConfigLoader, ProcessConfig, RestartPolicy, StaticConfigLoader};
+    use crate::config::{
+        ConfigLoader, MutableConfigLoader, ProcessConfig, ProcessDefinition, RestartPolicy,
+        StaticConfigLoader,
+    };
     use crate::state::ProcessState;
     use crate::test_helpers;
     use crate::uuid_gen::{SequentialUuidGenerator, UuidGenerator, V4UuidGenerator};
+    use std::sync::Arc;
 
     fn loader(defs: Vec<ProcessDefinition>) -> Arc<dyn ConfigLoader> {
         Arc::new(StaticConfigLoader::new(defs))
@@ -138,8 +140,7 @@ mod tests {
         Arc::new(V4UuidGenerator)
     }
 
-    fn test_runtime_handles(
-    ) -> (
+    fn test_runtime_handles() -> (
         RuntimeHandles,
         mpsc::Receiver<ExitEvent>,
         mpsc::Receiver<PendingRestart>,
@@ -255,8 +256,7 @@ mod tests {
             "reload should start the process with fresh counters"
         );
 
-        mgr.complete_restart(stale_pending, &handles)
-            .await;
+        mgr.complete_restart(stale_pending, &handles).await;
         let pid = mgr.processes().await[0].pid().unwrap();
         test_helpers::cleanup_process(pid);
         Ok(())
@@ -310,8 +310,7 @@ mod tests {
         mgr.handle_reload_config(&handles).await?;
         assert!(!mgr.processes().await[0].is_running());
 
-        mgr.complete_restart(stale_pending, &handles)
-            .await;
+        mgr.complete_restart(stale_pending, &handles).await;
         assert!(
             !mgr.processes().await[0].is_running(),
             "config reload should discard pending crash retries for failed auto_start=false processes"

pkg/procmgr/rust/src/manager/process_manager.rs

@@ -74,11 +74,7 @@ impl ProcessManager {
         self.config_loader.location()
     }
 
-    pub(in crate::manager) async fn handle_exit(
-        &self,
-        event: ExitEvent,
-        handles: &RuntimeHandles,
-    ) {
+    pub(in crate::manager) async fn handle_exit(&self, event: ExitEvent, handles: &RuntimeHandles) {
         let mut procs = self.processes.write().await;
         let Some(proc) = procs.iter_mut().find(|p| p.name() == event.name) else {
             warn!("exit event for unknown process '{}'", event.name);

pkg/procmgr/rust/src/manager/reload.rs

@@ -1,10 +1,10 @@
+use super::supervisor::RuntimeHandles;
 use super::{ProcessManager, queue_restart, try_spawn_and_watch};
 use crate::command::ReloadResult;
 use crate::config::ProcessDefinition;
 use crate::process::{ManagedProcess, ProcessOrigin};
 use crate::state::ProcessState;
 use log::{info, warn};
-use super::supervisor::RuntimeHandles;
 use tonic::Status;
 
 pub(super) struct ReloadConfigApplyResult {
@@ -133,8 +133,7 @@ impl ProcessManager {
             .apply_reloaded_config_processes(new_configs, handles)
             .await;
 
-        self.reconcile_processes_after_reload(&apply, handles)
-            .await;
+        self.reconcile_processes_after_reload(&apply, handles).await;
 
         self.update_startup_order().await;
         Ok(ReloadResult {

pkg/procmgr/rust/src/manager/supervisor.rs

@@ -16,7 +16,11 @@ pub(crate) struct RuntimeHandles {
 }
 
 impl RuntimeHandles {
-    pub(super) fn new() -> (Self, mpsc::Receiver<ExitEvent>, mpsc::Receiver<PendingRestart>) {
+    pub(super) fn new() -> (
+        Self,
+        mpsc::Receiver<ExitEvent>,
+        mpsc::Receiver<PendingRestart>,
+    ) {
         let (exit_tx, exit_rx) = mpsc::channel(256);
         let (restart_tx, restart_rx) = mpsc::channel(256);
         (
@@ -40,13 +44,23 @@ impl RuntimeHandles {
 
 async fn handle_command(manager: &ProcessManager, handles: &RuntimeHandles, cmd: Command) {
     match cmd {
-        Command::Create { name, config, reply } => {
+        Command::Create {
+            name,
+            config,
+            reply,
+        } => {
             let _ = reply.send(manager.handle_create(name, *config, handles).await);
         }
-        Command::Start { name_or_uuid, reply } => {
+        Command::Start {
+            name_or_uuid,
+            reply,
+        } => {
             let _ = reply.send(manager.handle_start(&name_or_uuid, handles).await);
         }
-        Command::Stop { name_or_uuid, reply } => {
+        Command::Stop {
+            name_or_uuid,
+            reply,
+        } => {
             let _ = reply.send(manager.handle_stop(&name_or_uuid).await);
         }
         Command::ReloadConfig { reply } => {
@@ -129,7 +143,7 @@ impl Supervisor {
     }
 }
 
-#[cfg(test)]
+#[cfg(all(test, unix))]
 pub(crate) fn spawn_command_loop_for_tests(
     manager: ProcessManager,
     mut cmd_rx: mpsc::Receiver<Command>,

pkg/procmgr/rust/src/process.rs

@@ -211,11 +211,6 @@ impl ManagedProcess {
         self.user_profile = Some(profile);
     }
 
-    #[cfg(windows)]
-    pub(crate) fn clear_windows_job_object(&mut self) {
-        self.job_object = None;
-    }
-
     #[cfg(windows)]
     pub(crate) fn clear_windows_spawn_resources(&mut self) {
         self.job_object = None;

pkg/procmgr/rust/src/transport/named_pipe.rs

@@ -19,7 +19,6 @@ use windows_sys::Win32::Foundation::HANDLE;
 
 use crate::platform::{create_pipe_server, pipe_client_may_mutate};
 
-const DEFAULT_PIPE_PATH: &str = r"\\.\pipe\datadog-procmgrd";
 const DEFAULT_PIPE_INSTANCES: usize = 4;
 
 pub fn ipc_path() -> PathBuf {