fix(logs): add logs about cache and lock strategy

aldor007 · Mar 16, 2022 · 59e7965 · 59e7965
1 parent 4602e26
commit 59e7965
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/pkg/cache/cache.go b/pkg/cache/cache.go
@@ -2,8 +2,10 @@ package cache
 
 import (
 	"github.com/aldor007/mort/pkg/config"
+	"github.com/aldor007/mort/pkg/monitoring"
 	"github.com/aldor007/mort/pkg/object"
 	"github.com/aldor007/mort/pkg/response"
+	"go.uber.org/zap"
 )
 
 // ResponseCache is interface for caching of mort responses
@@ -17,10 +19,13 @@ type ResponseCache interface {
 func Create(cacheCfg config.CacheCfg) ResponseCache {
 	switch cacheCfg.Type {
 	case "redis":
+		monitoring.Log().Info("Creating redis cache", zap.Strings("addr", cacheCfg.Address))
 		return NewRedis(cacheCfg.Address, cacheCfg.ClientConfig)
 	case "redis-cluster":
+		monitoring.Log().Info("Creating redis-cluster cache", zap.Strings("addr", cacheCfg.Address))
 		return NewRedisCluster(cacheCfg.Address, cacheCfg.ClientConfig)
 	default:
+		monitoring.Log().Info("Creating memory cache")
 		return NewMemoryCache(cacheCfg.CacheSize)
 	}
 }
diff --git a/pkg/lock/lock.go b/pkg/lock/lock.go
@@ -4,7 +4,9 @@ import (
 	"context"
 
 	"github.com/aldor007/mort/pkg/config"
+	"github.com/aldor007/mort/pkg/monitoring"
 	"github.com/aldor007/mort/pkg/response"
+	"go.uber.org/zap"
 )
 
 // Lock is responding for collapsing request for same object
@@ -64,14 +66,17 @@ func (l *NopLock) NotifyAndRelease(_ context.Context, _ string, _ *response.Resp
 
 func Create(lockCfg *config.LockCfg, lockTimeout int) Lock {
 	if lockCfg == nil {
+		monitoring.Log().Info("Creating memory lock")
 		return NewMemoryLock()
 	}
 	switch lockCfg.Type {
 	case "redis":
+		monitoring.Log().Info("Creating redis lock", zap.Strings("addr", lockCfg.Address), zap.Int("lockTimeout", lockTimeout))
 		r := NewRedisLock(lockCfg.Address, lockCfg.ClientConfig)
 		r.LockTimeout = lockTimeout
 		return r
 	case "redis-cluster":
+		monitoring.Log().Info("Creating redis-cluster lock", zap.Strings("addr", lockCfg.Address), zap.Int("lockTimeout", lockTimeout))
 		r := NewRedisCluster(lockCfg.Address, lockCfg.ClientConfig)
 		r.LockTimeout = lockTimeout
 		return r