SQUASH: provider Watch(ctx)

Signed-off-by: Dr. Stefan Schimanski <[email protected]>

Author: sttts

examples/fleet/main.go

@@ -126,7 +126,7 @@ func (k *KindClusterProvider) List(ctx context.Context) ([]string, error) {
 	return res, nil
 }
 
-func (k *KindClusterProvider) Watch() (cluster.Watcher, error) {
+func (k *KindClusterProvider) Watch(_ context.Context) (cluster.Watcher, error) {
 	return &KindWatcher{ch: make(chan cluster.WatchEvent)}, nil
 }
 

pkg/builder/controller_test.go

@@ -851,7 +851,7 @@ func (f *fakeClusterProvider) List(ctx context.Context) ([]string, error) {
 	return f.clusterNameList, f.listErr
 }
 
-func (f *fakeClusterProvider) Watch() (cluster.Watcher, error) {
+func (f *fakeClusterProvider) Watch(ctx context.Context) (cluster.Watcher, error) {
 	return &fakeLogicalWatcher{ch: f.watch}, nil
 }
 

pkg/cluster/provider.go

@@ -27,7 +27,7 @@ type Provider interface {
 
 	// Watch returns a Watcher that watches for changes to a list of known clusters
 	// and react to potential changes.
-	Watch() (Watcher, error)
+	Watch(ctx context.Context) (Watcher, error)
 }
 
 // Watcher watches for changes to clusters and provides events to a channel

pkg/manager/internal.go

@@ -612,7 +612,7 @@ func (cm *controllerManager) Start(ctx context.Context) (err error) { //nolint:g
 			}
 
 			// Create a watcher and start watching for changes.
-			watcher, err := cm.clusterProvider.Watch()
+			watcher, err := cm.clusterProvider.Watch(ctx)
 			if err != nil {
 				return err
 			}

pkg/manager/manager_test.go

@@ -2031,7 +2031,7 @@ func (f *fakeClusterAdapter) List(ctx context.Context) ([]string, error) {
 	return f.clusterNameList, f.listErr
 }
 
-func (f *fakeClusterAdapter) Watch() (cluster.Watcher, error) {
+func (f *fakeClusterAdapter) Watch(ctx context.Context) (cluster.Watcher, error) {
 	return &fakeLogicalClusterProvider{ch: f.watch}, nil
 }