Update collector to send data to remote in go routine

devzero-inc · Oct 7, 2024 · 494ba60 · 494ba60
1 parent a82fad9
commit 494ba60
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/collector/collector.go b/collector/collector.go
@@ -172,9 +172,11 @@ func (c *Collector) collectOnce() error {
 			)
 		}
 
-		if err := c.client.SendProcesses(processMetrics, c.protoAuthConfig); err != nil {
-			c.logger.Error().Err(err).Msg("Failed to send processes")
-		}
+		go func() {
+			if err := c.client.SendProcesses(processMetrics, c.protoAuthConfig); err != nil {
+				c.logger.Error().Err(err).Msg("Failed to send processes")
+			}
+		}()
 	}
 
 	return nil
@@ -348,9 +350,11 @@ func (c *Collector) handleEndCommand(parts []string) error {
 		c.onEndCommand()
 
 		if c.client != nil {
-			if err := c.client.SendCommands([]*gen.Command{MapCommandToProto(command)}, c.protoAuthConfig); err != nil {
-				c.logger.Error().Err(err).Msg("Failed to send command")
-			}
+			go func() {
+				if err := c.client.SendCommands([]*gen.Command{MapCommandToProto(command)}, c.protoAuthConfig); err != nil {
+					c.logger.Error().Err(err).Msg("Failed to send command")
+				}
+			}()
 		}
 	} else {
 		c.logger.Error().Msg("Matching start command not found")