Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetNamespacedName (0.3 sec)

  1. pkg/scheduler/internal/cache/snapshot.go

    		if pod.Spec.NodeName == "" {
    			continue
    		}
    
    		for _, v := range pod.Spec.Volumes {
    			if v.PersistentVolumeClaim == nil {
    				continue
    			}
    
    			key := framework.GetNamespacedName(pod.Namespace, v.PersistentVolumeClaim.ClaimName)
    			usedPVCSet.Insert(key)
    		}
    	}
    	return usedPVCSet
    }
    
    // getNodeImageStates returns the given node's image states based on the given imageExistence map.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/types.go

    	uid := string(pod.UID)
    	if len(uid) == 0 {
    		return "", errors.New("cannot get cache key for pod with empty UID")
    	}
    	return uid, nil
    }
    
    // GetNamespacedName returns the string format of a namespaced resource name.
    func GetNamespacedName(namespace, name string) string {
    	return fmt.Sprintf("%s/%s", namespace, name)
    }
    
    // DefaultBindAllHostIP defines the default ip address used to bind to all host.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    func (pl *VolumeRestrictions) calPreFilterState(ctx context.Context, pod *v1.Pod, pvcs sets.Set[string]) (*preFilterState, error) {
    	conflictingPVCRefCount := 0
    	for pvc := range pvcs {
    		key := framework.GetNamespacedName(pod.Namespace, pvc)
    		if pl.sharedLister.StorageInfos().IsPVCUsedByPods(key) {
    			// There can only be at most one pod using the ReadWriteOncePod PVC.
    			conflictingPVCRefCount += 1
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
Back to top