on main help sign in
small things
ed3518dKujtim Hoxha
cmd/root.go+4−4
@@ -182,7 +182,7 @@ func setupSubscriber[T any](
182 select {
182 select {
183 case event, ok := <-subCh:
183 case event, ok := <-subCh:
184 if !ok {
184 if !ok {
185− logging.Info("%s subscription channel closed", name)
185+ logging.Info("subscription channel closed", "name", name)
186 return
186 return
187 }
187 }
188
188
@@ -191,13 +191,13 @@ func setupSubscriber[T any](
191 select {
191 select {
192 case outputCh <- msg:
192 case outputCh <- msg:
193 case <-time.After(2 * time.Second):
193 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)
195 case <-ctx.Done():
195 case <-ctx.Done():
196− logging.Info("%s subscription cancelled", name)
196+ logging.Info("subscription cancelled", "name", name)
197 return
197 return
198 }
198 }
199 case <-ctx.Done():
199 case <-ctx.Done():
200− logging.Info("%s subscription cancelled", name)
200+ logging.Info("subscription cancelled", "name", name)
201 return
201 return
202 }
202 }
203 }
203 }
internal/db/connect.go+2−2
@@ -48,9 +48,9 @@ func Connect() (*sql.DB, error) {
48
48
49 for _, pragma := range pragmas {
49 for _, pragma := range pragmas {
50 if _, err = db.Exec(pragma); err != nil {
50 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)
52 } else {
52 } else {
53− logging.Warn("Set pragma", "pragma", pragma)
53+ logging.Debug("Set pragma", "pragma", pragma)
54 }
54 }
55 }
55 }
56
56