There was an error while loading. Please reload this page.
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