Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for GetExistingClustersFor (0.32 sec)

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