diff options
| author | Kujtim Hoxha <[email protected]> | 2025-04-21 16:24:38 +0200 |
|---|---|---|
| committer | Kujtim Hoxha <[email protected]> | 2025-04-21 16:24:38 +0200 |
| commit | ed3518d0755cb5cae25d9d8f1690ab2e60702588 (patch) | |
| tree | 8273209b12c3da29b517231061dda87938118113 /cmd | |
| parent | d03a73a8d36565cf00ccdee0b1689f295999ad51 (diff) | |
| download | opencode-ed3518d0755cb5cae25d9d8f1690ab2e60702588.tar.gz opencode-ed3518d0755cb5cae25d9d8f1690ab2e60702588.zip | |
small things
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/root.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cmd/root.go b/cmd/root.go index 545652a7a..8777acb82 100644 --- a/cmd/root.go +++ b/cmd/root.go @@ -182,7 +182,7 @@ func setupSubscriber[T any]( select { case event, ok := <-subCh: if !ok { - logging.Info("%s subscription channel closed", name) + logging.Info("subscription channel closed", "name", name) return } @@ -191,13 +191,13 @@ func setupSubscriber[T any]( select { case outputCh <- msg: case <-time.After(2 * time.Second): - logging.Warn("%s message dropped due to slow consumer", name) + logging.Warn("message dropped due to slow consumer", "name", name) case <-ctx.Done(): - logging.Info("%s subscription cancelled", name) + logging.Info("subscription cancelled", "name", name) return } case <-ctx.Done(): - logging.Info("%s subscription cancelled", name) + logging.Info("subscription cancelled", "name", name) return } } |
