summaryrefslogtreecommitdiffhomepage
path: root/cmd
diff options
context:
space:
mode:
authorKujtim Hoxha <[email protected]>2025-04-21 16:24:38 +0200
committerKujtim Hoxha <[email protected]>2025-04-21 16:24:38 +0200
commited3518d0755cb5cae25d9d8f1690ab2e60702588 (patch)
tree8273209b12c3da29b517231061dda87938118113 /cmd
parentd03a73a8d36565cf00ccdee0b1689f295999ad51 (diff)
downloadopencode-ed3518d0755cb5cae25d9d8f1690ab2e60702588.tar.gz
opencode-ed3518d0755cb5cae25d9d8f1690ab2e60702588.zip
small things
Diffstat (limited to 'cmd')
-rw-r--r--cmd/root.go8
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
}
}