Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for clusterDeleted (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top