Skip to content

Commit

Permalink
fix(federated-informer-manager): fix cluster deletion
Browse files Browse the repository at this point in the history
  • Loading branch information
limhawjia committed Jul 25, 2023
1 parent 26f222d commit 5e2ab29
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion pkg/util/informermanager/federatedinformermanager.go
Original file line number Diff line number Diff line change
Expand Up @@ -283,13 +283,15 @@ func (m *federatedInformerManager) processClusterDeletion(ctx context.Context, c

func (m *federatedInformerManager) processClusterDeletionUnlocked(ctx context.Context, clusterName string) error {
delete(m.connectionMap, clusterName)
delete(m.kubeClients, clusterName)
delete(m.dynamicClients, clusterName)

if cancel, ok := m.clusterCancelFuncs[clusterName]; ok {
klog.FromContext(ctx).V(2).Info("Stopping InformerManager for FederatedCluster")
klog.FromContext(ctx).V(2).Info("Stopping InformerManager and SharedInformerFactory for FederatedCluster")
cancel()
}
delete(m.informerManagers, clusterName)
delete(m.informerFactories, clusterName)
delete(m.clusterCancelFuncs, clusterName)

m.initialClusters.Delete(clusterName)
Expand Down

0 comments on commit 5e2ab29

Please sign in to comment.