- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for GetExistingClustersFor (0.32 sec)
-
pkg/kube/multicluster/clusterstore.go
for cid, c := range clusters { outCluster := *c out[secret][cid] = &outCluster } } return out } // GetExistingClustersFor return existing clusters registered for the given secret func (c *ClusterStore) GetExistingClustersFor(secretKey string) []*Cluster { c.RLock() defer c.RUnlock() out := make([]*Cluster, 0, len(c.remoteClusters[secretKey]))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 07 15:01:12 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
}, nil } func (c *Controller) addSecret(name types.NamespacedName, s *corev1.Secret) error { secretKey := name.String() // First delete clusters existingClusters := c.cs.GetExistingClustersFor(secretKey) for _, existingCluster := range existingClusters { if _, ok := s.Data[string(existingCluster.ID)]; !ok { c.deleteCluster(secretKey, existingCluster) } } var errs *multierror.Error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0)