fix: don't log an error when docker events listener exits cleanly (#4907)
Co-authored-by: Claude Opus 5 (1M context) <noreply@anthropic.com>
This commit is contained in:
co-authored by
Claude Opus 5
parent
b944b52495
commit
be30692e62
@@ -101,7 +101,7 @@ func (s *ContainerStore) checkConnectivity() error {
|
||||
go func() {
|
||||
log.Debug().Str("host", s.client.Host().Name).Msg("docker store subscribing docker events")
|
||||
err := s.client.ContainerEvents(s.ctx, s.events)
|
||||
if !errors.Is(err, context.Canceled) {
|
||||
if err != nil && !errors.Is(err, context.Canceled) {
|
||||
log.Error().Err(err).Str("host", s.client.Host().Name).Msg("docker store unexpectedly disconnected from docker events")
|
||||
}
|
||||
s.connected.Store(false)
|
||||
|
||||
@@ -118,7 +118,7 @@ func (sc *DockerStatsCollector) Start(parentCtx context.Context) bool {
|
||||
defer close(events)
|
||||
log.Debug().Str("host", sc.client.Host().Name).Msg("starting to listen to docker events")
|
||||
err := sc.client.ContainerEvents(ctx, events)
|
||||
if !errors.Is(err, context.Canceled) {
|
||||
if err != nil && !errors.Is(err, context.Canceled) {
|
||||
log.Error().Str("host", sc.client.Host().Name).Err(err).Msg("unexpected error while listening to docker events")
|
||||
}
|
||||
sc.forceStop()
|
||||
|
||||
Reference in New Issue
Block a user