add logger to manager events handler

Signed-off-by: Pavel Okhlopkov <[email protected]>

pkg/app/log.go

@@ -65,15 +65,13 @@ func SetupLogging(runtimeConfig *config.Config, logger *unilogger.Logger) {
 	// 	log.SetFormatter(&ProxyJsonWrapperFormatter{WrappedFormatter: formatter})
 	// }
 
-	logger.SetLevel(unilogger.LogLevelFromStr(LogLevel))
 	unilogger.SetDefaultLevel(unilogger.LogLevelFromStr(LogLevel))
 
 	runtimeConfig.Register("log.level",
 		fmt.Sprintf("Global log level. Default duration for debug level is %s", ForcedDurationForDebugLevel),
 		strings.ToLower(LogLevel),
 		func(oldValue string, newValue string) error {
 			log.Infof("Set log level to '%s'", newValue)
-			logger.SetLevel(unilogger.LogLevelFromStr(newValue))
 			unilogger.SetDefaultLevel(unilogger.LogLevelFromStr(LogLevel))
 			return nil
 		}, func(oldValue string, newValue string) time.Duration {

pkg/shell-operator/bootstrap.go

@@ -161,9 +161,10 @@ func (op *ShellOperator) SetupEventManagers() {
 
 	// Initialize events handler that emit tasks to run hooks
 	cfg := &managerEventsHandlerConfig{
-		tqs:  op.TaskQueues,
-		mgr:  op.KubeEventsManager,
-		smgr: op.ScheduleManager,
+		tqs:    op.TaskQueues,
+		mgr:    op.KubeEventsManager,
+		smgr:   op.ScheduleManager,
+		logger: op.logger.Named("manager-events-handler"),
 	}
 	op.ManagerEventsHandler = newManagerEventsHandler(op.ctx, cfg)
 }

pkg/shell-operator/manager_events_handler.go

@@ -18,7 +18,7 @@ type managerEventsHandlerConfig struct {
 	mgr  kube_events_manager.KubeEventsManager
 	smgr schedule_manager.ScheduleManager
 
-	Logger *unilogger.Logger
+	logger *unilogger.Logger
 }
 
 type ManagerEventsHandler struct {
@@ -48,7 +48,7 @@ func newManagerEventsHandler(ctx context.Context, cfg *managerEventsHandlerConfi
 		scheduleManager:   cfg.smgr,
 		kubeEventsManager: cfg.mgr,
 		taskQueues:        cfg.tqs,
-		logger:            cfg.Logger,
+		logger:            cfg.logger,
 	}
 }