- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for clusterDeleted (0.16 sec)
-
pkg/kube/multicluster/fake.go
ID: id, Client: client, kubeConfigSha: [32]byte{}, stop: stop, }) } } func (f *Fake) Delete(id cluster.ID) { for _, handler := range f.handlers { handler.clusterDeleted(id) } } func NewFakeController() *Fake { return &Fake{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 1.2K bytes - Viewed (0) -
pkg/kube/multicluster/component.go
m.mu.Lock() m.clusters[cluster.ID] = comp m.mu.Unlock() // Close outside of the lock, in case its slow if f { old.Close() } return comp } func (m *Component[T]) clusterDeleted(cluster cluster.ID) { m.mu.Lock() defer m.mu.Unlock() // If there is an old one, close it if old, f := m.clusters[cluster]; f { old.Close() } delete(m.clusters, cluster) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
remoteClusters = clustersCount.With(clusterType.Value("remote")) ) type handler interface { clusterAdded(cluster *Cluster) ComponentConstraint clusterUpdated(cluster *Cluster) ComponentConstraint clusterDeleted(clusterID cluster.ID) HasSynced() bool } // ClientBuilder builds a new kube.Client from a kubeconfig. Mocked out for testing
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0)