ed3518d · crush · git.iko.soy

small things

commited3518d0755cb5cae25d9d8f1690ab2e60702588 authorKujtim Hoxha <kujtimii.h@gmail.com> dateMon 21 Apr 2025, 16:24 (2 years ago) parentd03a73a

2 files changed+6−6

unifiedsplit

cmd/root.go+4−4

@@ -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 }

internal/db/connect.go+2−2

@@ -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