- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetNamespacedName (0.3 sec)
-
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) -
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) -
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)