From fd0a74bcea0e3a43db2a34348690ca4bbc7ac89a Mon Sep 17 00:00:00 2001 From: Luke Rogerson Date: Mon, 25 Mar 2024 12:14:29 +0000 Subject: [PATCH] Reduce log level --- data/redisrepo/pub_sub.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/data/redisrepo/pub_sub.go b/data/redisrepo/pub_sub.go index 01a40b7..cdeddaa 100644 --- a/data/redisrepo/pub_sub.go +++ b/data/redisrepo/pub_sub.go @@ -17,13 +17,13 @@ func (r *redisRepository) PublishEvent(ctx context.Context, key string, value in return fmt.Errorf("failed to publish redis event: %v", err) } - logctx.Info(ctx, "published redis event", logger.String("key", key)) + logctx.Debug(ctx, "published redis event", logger.String("key", key)) return nil } // SubscribeToEvents subscribes to events on a given Redis channel func (r *redisRepository) SubscribeToEvents(ctx context.Context, channel string) (chan []byte, error) { - logctx.Info(ctx, "subscribing to channel", logger.String("channel", channel)) + logctx.Debug(ctx, "subscribing to channel", logger.String("channel", channel)) // Subscribe to the specified channel pubsub := r.client.Subscribe(ctx, channel) @@ -45,7 +45,7 @@ func (r *redisRepository) SubscribeToEvents(ctx context.Context, channel string) for msg := range ch { messages <- []byte(msg.Payload) } - logctx.Info(ctx, "subscription ended", logger.String("channel", channel)) + logctx.Debug(ctx, "subscription ended", logger.String("channel", channel)) close(messages) }()