Revert "Enable go-redis logger"

This reverts commit a358354. Set global redis logger is not safe in multiple nodes situation.
centrifugal · Aug 3, 2022 · 67b3d05 · 67b3d05
1 parent 4ecfa17
commit 67b3d05
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 8 deletions.
diff --git a/node.go b/node.go
@@ -11,8 +11,6 @@ import (
 	"sync"
 	"time"
 
-	"github.com/go-redis/redis/v8"
-
 	"github.com/centrifugal/centrifuge/internal/controlpb"
 	"github.com/centrifugal/centrifuge/internal/controlproto"
 	"github.com/centrifugal/centrifuge/internal/dissolve"
@@ -162,7 +160,6 @@ func New(c Config) (*Node, error) {
 	if c.LogHandler != nil {
 		n.logger = newLogger(c.LogLevel, c.LogHandler)
 	}
-	redis.SetLogger(redisLogger{n})
 
 	b, err := NewMemoryBroker(n, MemoryBrokerConfig{})
 	if err != nil {

diff --git a/redis_shard.go b/redis_shard.go
@@ -38,12 +38,12 @@ const (
 	redisDataBatchLimit = 64
 )
 
-type redisLogger struct{
-	n *Node
-}
+type redisLogger struct{}
+
+func (redisLogger) Printf(ctx context.Context, format string, v ...interface{}) {}
 
-func (l redisLogger) Printf(ctx context.Context, format string, v ...interface{}) {
-	l.n.Log(NewLogEntry(LogLevelInfo, fmt.Sprintf(format, v...)))
+func init() {
+	redis.SetLogger(redisLogger{})
 }
 
 type RedisShard struct {