diff --git a/export_test.go b/export_test.go index 00b2b91d..7d2d1833 100644 --- a/export_test.go +++ b/export_test.go @@ -87,7 +87,7 @@ func (c *clusterState) IsConsistent(ctx context.Context) bool { func GetSlavesAddrByName(ctx context.Context, c *SentinelClient, name string) []string { addrs, err := c.Replicas(ctx, name).Result() if err != nil { - logging.LoggerWithLevel.Errorf(ctx, "sentinel: Replicas name=%q failed: %s", + logging.LoggerWithLevel().Errorf(ctx, "sentinel: Replicas name=%q failed: %s", name, err) return []string{} } diff --git a/internal/auth/streaming/pool_hook.go b/internal/auth/streaming/pool_hook.go index eec8d2fc..29c42103 100644 --- a/internal/auth/streaming/pool_hook.go +++ b/internal/auth/streaming/pool_hook.go @@ -7,6 +7,7 @@ import ( "github.com/redis/go-redis/v9/internal" "github.com/redis/go-redis/v9/internal/pool" + "github.com/redis/go-redis/v9/logging" ) // ReAuthPoolHook is a pool hook that manages background re-authentication of connections @@ -166,7 +167,7 @@ func (r *ReAuthPoolHook) OnPut(_ context.Context, conn *pool.Conn) (bool, bool, defer func() { if rec := recover(); rec != nil { // once again - safety first - LoggerWrapper.Printf(context.Background(), "panic in reauth worker: %v", rec) + logging.LoggerWithLevel().Errorf(context.Background(), "panic in reauth worker: %v", rec) } r.scheduledLock.Lock() delete(r.scheduledReAuth, connID)