This repository was archived by the owner on Sep 18, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 2 files changed +6
-6
lines changed
Expand file tree Collapse file tree 2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -182,7 +182,7 @@ func setupSubscriber[T any](
182182 select {
183183 case event , ok := <- subCh :
184184 if ! ok {
185- logging .Info ("%s subscription channel closed" , name )
185+ logging .Info ("subscription channel closed" , "name " , name )
186186 return
187187 }
188188
@@ -191,13 +191,13 @@ func setupSubscriber[T any](
191191 select {
192192 case outputCh <- msg :
193193 case <- time .After (2 * time .Second ):
194- logging .Warn ("%s message dropped due to slow consumer" , name )
194+ logging .Warn ("message dropped due to slow consumer" , "name " , name )
195195 case <- ctx .Done ():
196- logging .Info ("%s subscription cancelled" , name )
196+ logging .Info ("subscription cancelled" , "name " , name )
197197 return
198198 }
199199 case <- ctx .Done ():
200- logging .Info ("%s subscription cancelled" , name )
200+ logging .Info ("subscription cancelled" , "name " , name )
201201 return
202202 }
203203 }
Original file line number Diff line number Diff line change @@ -48,9 +48,9 @@ func Connect() (*sql.DB, error) {
4848
4949 for _ , pragma := range pragmas {
5050 if _ , err = db .Exec (pragma ); err != nil {
51- logging .Warn ("Failed to set pragma" , pragma , err )
51+ logging .Error ("Failed to set pragma" , pragma , err )
5252 } else {
53- logging .Warn ("Set pragma" , "pragma" , pragma )
53+ logging .Debug ("Set pragma" , "pragma" , pragma )
5454 }
5555 }
5656
You can’t perform that action at this time.
0 commit comments