@@ -139,7 +139,7 @@ func (m *Manager) WithHandlers(reg map[database.NotificationMethod]Handler) {
139
139
// Manager requires system-level permissions to interact with the store.
140
140
// Run is only intended to be run once.
141
141
func (m * Manager ) Run (ctx context.Context ) {
142
- m .log .Info (ctx , "notification manager started" )
142
+ m .log .Debug (ctx , "notification manager started" )
143
143
144
144
m .runOnce .Do (func () {
145
145
// Closes when Stop() is called or context is canceled.
@@ -157,7 +157,7 @@ func (m *Manager) Run(ctx context.Context) {
157
157
func (m * Manager ) loop (ctx context.Context ) error {
158
158
defer func () {
159
159
close (m .done )
160
- m .log .Info (context .Background (), "notification manager stopped" )
160
+ m .log .Debug (context .Background (), "notification manager stopped" )
161
161
}()
162
162
163
163
m .mu .Lock ()
@@ -359,7 +359,7 @@ func (m *Manager) Stop(ctx context.Context) error {
359
359
}
360
360
m .closed = true
361
361
362
- m .log .Info (context .Background (), "graceful stop requested" )
362
+ m .log .Debug (context .Background (), "graceful stop requested" )
363
363
364
364
// If the notifier hasn't been started, we don't need to wait for anything.
365
365
// This is only really during testing when we want to enqueue messages only but not deliver them.
@@ -388,7 +388,7 @@ func (m *Manager) Stop(ctx context.Context) error {
388
388
m .log .Error (context .Background (), "graceful stop failed" , slog .F ("err" , errStr ))
389
389
return ctx .Err ()
390
390
case <- m .done :
391
- m .log .Info (context .Background (), "gracefully stopped" )
391
+ m .log .Debug (context .Background (), "gracefully stopped" )
392
392
return nil
393
393
}
394
394
}
0 commit comments