From b55d9cbe883cf9c6d1413ec4544cf68981fd89b3 Mon Sep 17 00:00:00 2001 From: Laurence Date: Fri, 2 May 2025 14:14:55 +0100 Subject: [PATCH] enhance: Move info to reconnect goto --- pkg/acquisition/modules/docker/docker.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/acquisition/modules/docker/docker.go b/pkg/acquisition/modules/docker/docker.go index 8a7ffc701..d69ccb18a 100644 --- a/pkg/acquisition/modules/docker/docker.go +++ b/pkg/acquisition/modules/docker/docker.go @@ -585,7 +585,7 @@ func (d *DockerSource) WatchContainer(ctx context.Context, monitChan chan *Conta // Multiple retry attempts within the error case retries := 0 - d.logger.Infof("Attempting to reconnect to Docker events stream") + d.logger.Info("Attempting to reconnect to Docker events stream") for { // Check for cancellation before sleeping select { @@ -628,13 +628,13 @@ func (d *DockerSource) WatchContainer(ctx context.Context, monitChan chan *Conta default: // No immediate error, seems to have reconnected successfully errorRetryBackoff = initialBackoff - d.logger.Info("Successfully reconnected to Docker events") eventsChan = newEventsChan errChan = newErrChan goto reconnected } } reconnected: + d.logger.Info("Successfully reconnected to Docker events") // We check containers after a reconnection because the docker daemon might have restarted // and the container tombs may have self deleted d.checkContainers(ctx, monitChan, deleteChan)