From bf516641f9d8d680f8bd9afe50817bb564ac9de1 Mon Sep 17 00:00:00 2001 From: dsv Date: Mon, 2 Sep 2024 17:36:49 +0200 Subject: [PATCH] fix: enhance error logging for channel and sync registries - Change logging level from Debug to Warn for error messages in channel registry and sync registry files. - Improve error visibility by logging warnings instead of debug information for failed event sends. Signed-off-by: dsv --- pkg/exporter/channel_registry.go | 2 +- pkg/exporter/sync_registry.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/exporter/channel_registry.go b/pkg/exporter/channel_registry.go index 39db655a..4f5ff0e4 100644 --- a/pkg/exporter/channel_registry.go +++ b/pkg/exporter/channel_registry.go @@ -59,7 +59,7 @@ func (r *ChannelBasedReceiverRegistry) Register(name string, receiver sinks.Sink err := receiver.Send(context.Background(), &ev) if err != nil { r.MetricsStore.SendErrors.Inc() - log.Debug().Err(err).Str("sink", name).Str("event", ev.Message).Msg("Cannot send event") + log.Warn().Err(err).Str("sink", name).Str("event", ev.Message).Msg("Cannot send event") } case <-exitCh: log.Info().Str("sink", name).Msg("Closing the sink") diff --git a/pkg/exporter/sync_registry.go b/pkg/exporter/sync_registry.go index 8c6294ec..c7abd4d3 100644 --- a/pkg/exporter/sync_registry.go +++ b/pkg/exporter/sync_registry.go @@ -16,7 +16,7 @@ type SyncRegistry struct { func (s *SyncRegistry) SendEvent(name string, event *kube.EnhancedEvent) { err := s.reg[name].Send(context.Background(), event) if err != nil { - log.Debug().Err(err).Str("sink", name).Str("event", string(event.UID)).Msg("Cannot send event") + log.Warn().Err(err).Str("sink", name).Str("event", string(event.UID)).Msg("Cannot send event") } }