We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8f7e114 commit aa3f342Copy full SHA for aa3f342
āpkg/internal/controller/controller.go
@@ -175,7 +175,16 @@ func (c *Controller[request]) Start(ctx context.Context) error {
175
// caches.
176
errGroup := &errgroup.Group{}
177
for _, watch := range c.startWatches {
178
- log := c.LogConstructor(nil).WithValues("source", fmt.Sprintf("%s", watch))
+ log := c.LogConstructor(nil)
179
+ _, ok := watch.(interface {
180
+ String() string
181
+ })
182
+
183
+ if !ok {
184
+ log = log.WithValues("source", fmt.Sprintf("%T", watch))
185
+ } else {
186
+ log = log.WithValues("source", fmt.Sprintf("%s", watch))
187
+ }
188
didStartSyncingSource := &atomic.Bool{}
189
errGroup.Go(func() error {
190
// Use a timeout for starting and syncing the source to avoid silently
0 commit comments