Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for nodeInfoAnnotations (0.12 sec)

  1. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    	if migratedPlugins == nil {
    		return false
    	}
    
    	nodeInfoAnnotations := nodeInfo.GetAnnotations()
    	if nodeInfoAnnotations == nil {
    		nodeInfoAnnotations = map[string]string{}
    	}
    
    	var oldAnnotationSet sets.Set[string]
    	mpa := nodeInfoAnnotations[v1.MigratedPluginsAnnotationKey]
    	tok := strings.Split(mpa, ",")
    	if len(mpa) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  2. pkg/volume/testing/volume_host.go

    func enableMigrationOnNode(csiNode *storagev1.CSINode, pluginName string) {
    	nodeInfoAnnotations := csiNode.GetAnnotations()
    	if nodeInfoAnnotations == nil {
    		nodeInfoAnnotations = map[string]string{}
    	}
    
    	newAnnotationSet := sets.New[string]()
    	newAnnotationSet.Insert(pluginName)
    	nas := strings.Join(sets.List(newAnnotationSet), ",")
    	nodeInfoAnnotations[v1.MigratedPluginsAnnotationKey] = nas
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    func enableMigrationOnNode(csiNode *storagev1.CSINode, pluginName string) {
    	nodeInfoAnnotations := csiNode.GetAnnotations()
    	if nodeInfoAnnotations == nil {
    		nodeInfoAnnotations = map[string]string{}
    	}
    
    	newAnnotationSet := sets.New[string]()
    	newAnnotationSet.Insert(pluginName)
    	nas := strings.Join(sets.List(newAnnotationSet), ",")
    	nodeInfoAnnotations[v1.MigratedPluginsAnnotationKey] = nas
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
Back to top