feat: remove space

Author: danielorihuela

agent-control/src/agent_control/http_server/async_bridge.rs

@@ -14,7 +14,7 @@ pub fn run_async_sync_bridge(
     agent_control_consumer: EventConsumer<AgentControlEvent>,
     sub_agent_consumer: EventConsumer<SubAgentEvent>,
 ) -> JoinHandle<()> {
-    thread::Builder::new().name("AC sync events to/from Status Http server async events bridge ".to_string()).spawn(move || loop {
+    thread::Builder::new().name("AC sync events to/from Status Http server async events bridge".to_string()).spawn(move || loop {
         select! {
             recv(&agent_control_consumer.as_ref()) -> sa_event_res => {
                 match sa_event_res {

agent-control/src/agent_control/http_server/runner.rs

@@ -56,7 +56,7 @@ impl Runner {
         maybe_opamp_client_config: Option<OpAMPClientConfig>,
     ) -> JoinHandle<()> {
         thread::Builder::new()
-            .name("Http server ".to_string())
+            .name("Http server".to_string())
             .spawn(move || {
                 // Create 2 unbounded channel to send the Agent Control and Sub Agent Sync events
                 // to the Async Status Server
@@ -98,7 +98,7 @@ impl Runner {
         sub_agent_consumer: EventConsumer<SubAgentEvent>,
     ) -> JoinHandle<()> {
         thread::Builder::new()
-            .name("No-action consumer ".to_string())
+            .name("No-action consumer".to_string())
             .spawn(move || loop {
                 select! {
                     recv(agent_control_consumer.as_ref()) -> agent_control_consumer_res => {

agent-control/src/k8s/garbage_collector.rs

@@ -86,7 +86,7 @@ where
         let interval = self.interval;
 
         let handle = thread::Builder::new()
-            .name("Garbage collector ".to_string())
+            .name("Garbage collector".to_string())
             .spawn(move || {
                 loop {
                     let _ = self

agent-control/src/sub_agent/health/health_checker.rs

@@ -221,7 +221,7 @@ pub(crate) fn spawn_health_checker<H>(
     H: HealthChecker + Send + 'static,
 {
     thread::Builder::new()
-        .name("Health checker ".to_string())
+        .name("Health checker".to_string())
         .spawn(move || loop {
             debug!(%agent_id, "starting to check health with the configured checker");
 

agent-control/src/sub_agent/k8s/supervisor.rs

@@ -132,7 +132,7 @@ impl NotStartedSupervisorK8s {
 
         info!(%agent_id, "k8s objects supervisor started");
         let join_handle = thread::Builder::new()
-            .name("K8s objects supervisor ".to_string())
+            .name("K8s objects supervisor".to_string())
             .spawn(move || loop {
                 // Check and apply k8s objects
                 if let Err(err) =

agent-control/src/sub_agent/on_host/command/logging/logger.rs

@@ -15,7 +15,7 @@ impl Logger {
         S: ToString + Send + 'static,
     {
         std::thread::Builder::new()
-            .name("OnHost logger ".to_string())
+            .name("OnHost logger".to_string())
             .spawn(move || {
                 match self {
                     Self::File(file_logger, agent_id) => {

agent-control/src/sub_agent/on_host/command/logging/thread.rs

@@ -27,7 +27,7 @@ where
 
     // In a separate thread, iterate over the handle to get the logs
     let sender_thread = std::thread::Builder::new()
-        .name("OnHost log sender ".to_string())
+        .name("OnHost log sender".to_string())
         .spawn(move || {
             let log_entries = BufReader::new(handle).lines();
             for line in log_entries {

agent-control/src/sub_agent/on_host/supervisor.rs

@@ -181,7 +181,7 @@ impl NotStartedSupervisorOnHost {
             shutdown_ctx.clone(),
             self.agent_id.clone(),
         );
-        thread::Builder::new().name("OnHost process ".to_string()).spawn({
+        thread::Builder::new().name("OnHost process".to_string()).spawn({
             move || loop {
                 // locks the current_pid to prevent `wait_for_termination` finishing before the process
                 // is started and the pid is set.
@@ -371,7 +371,7 @@ fn wait_for_termination(
     agent_id: AgentID,
 ) -> JoinHandle<()> {
     thread::Builder::new()
-        .name("OnHost Termination signal listener ".to_string())
+        .name("OnHost Termination signal listener".to_string())
         .spawn(move || {
             let (lck, cvar) = Context::get_lock_cvar(&ctx);
             drop(cvar.wait_while(lck.lock().unwrap(), |finish| !*finish));

agent-control/src/sub_agent/sub_agent.rs

@@ -139,7 +139,7 @@ where
     }
 
     pub fn runtime(self) -> JoinHandle<Result<(), SubAgentError>> {
-        thread::Builder::new().name("SubAgent runtime ".to_string()).spawn(move || {
+        thread::Builder::new().name("SubAgent runtime".to_string()).spawn(move || {
             let mut supervisor = self.assemble_and_start_supervisor();
 
             // Stores the current healthy state for logging purposes.

agent-control/src/sub_agent/version/version_checker.rs

@@ -51,7 +51,7 @@ pub(crate) fn spawn_version_checker<V>(
     V: VersionChecker + Send + Sync + 'static,
 {
     thread::Builder::new()
-        .name("Version checker ".to_string())
+        .name("Version checker".to_string())
         .spawn(move || loop {
             debug!(%agent_id, "starting to check version with the configured checker");