During resync, remove clusters that are no longer found

Signed-off-by: Vince Prignano <[email protected]>

Author: vincepri

pkg/manager/internal.go

@@ -31,6 +31,7 @@ import (
 	"k8s.io/apimachinery/pkg/api/meta"
 	"k8s.io/apimachinery/pkg/runtime"
 	kerrors "k8s.io/apimachinery/pkg/util/errors"
+	"k8s.io/apimachinery/pkg/util/sets"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/apimachinery/pkg/watch"
 	"k8s.io/client-go/rest"
@@ -630,6 +631,15 @@ func (cm *controllerManager) Start(ctx context.Context) (err error) { //nolint:g
 						return err
 					}
 				}
+				clusterListSet := sets.New(clusterList...)
+				for name := range cm.logicalClusters {
+					if clusterListSet.Has(name) {
+						continue
+					}
+					if err := cm.removeLogicalCluster(name); err != nil {
+						return err
+					}
+				}
 				cm.syncClusterAwareRunnables()
 				return nil
 			}