Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for VolumeIsForPod (0.28 sec)

  1. pkg/controller/volume/ephemeral/controller.go

    	pvc, err := ec.pvcLister.PersistentVolumeClaims(pod.Namespace).Get(pvcName)
    	if err != nil && !errors.IsNotFound(err) {
    		return err
    	}
    	if pvc != nil {
    		if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    			return err
    		}
    		// Already created, nothing more to do.
    		logger.V(5).Info("Ephemeral: PVC already created", "volumeName", vol.Name, "PVC", klog.KObj(pvc))
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. pkg/controller/volume/attachdetach/util/util.go

    		if err != nil {
    			return nil, fmt.Errorf(
    				"error processing PVC %q/%q: %v",
    				pod.Namespace,
    				claimName,
    				err)
    		}
    		if isEphemeral {
    			if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    				return nil, err
    			}
    		}
    
    		pvName, pvcUID := pvc.Spec.VolumeName, pvc.UID
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    		}
    
    		if pvc.DeletionTimestamp != nil {
    			return hasPVC, fmt.Errorf("persistentvolumeclaim %q is being deleted", pvc.Name)
    		}
    
    		if isEphemeral {
    			if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    				return hasPVC, err
    			}
    		}
    	}
    	return hasPVC, nil
    }
    
    // PreFilter invoked at the prefilter extension point to check if pod has all
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  4. pkg/controller/volume/pvcprotection/pvc_protection_controller.go

    			if volume.PersistentVolumeClaim != nil && volume.PersistentVolumeClaim.ClaimName == pvc.Name ||
    				!podIsShutDown(pod) && volume.Ephemeral != nil && ephemeral.VolumeClaimName(pod, &volume) == pvc.Name && ephemeral.VolumeIsForPod(pod, pvc) == nil {
    				logger.V(2).Info("Pod uses PVC", "pod", klog.KObj(pod), "PVC", klog.KObj(pvc))
    				return true
    			}
    		}
    	}
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 14K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    			continue
    		}
    
    		// The PVC for an ephemeral volume must be owned by the pod.
    		if isEphemeral {
    			if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    				return err
    			}
    		}
    
    		driverName, volumeHandle := pl.getCSIDriverInfo(logger, csiNode, pvc)
    		if driverName == "" || volumeHandle == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go

    			continue
    		}
    
    		// The PVC for an ephemeral volume must be owned by the pod.
    		if isEphemeral {
    			if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    				return err
    			}
    		}
    
    		pvName := pvc.Spec.VolumeName
    		if pvName == "" {
    			// PVC is not bound. It was either deleted and created again or
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go

    		if err != nil {
    			return nil, nil, "", fmt.Errorf(
    				"error processing PVC %s/%s: %v",
    				pod.Namespace,
    				pvcSource.ClaimName,
    				err)
    		}
    		if isEphemeral {
    			if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    				return nil, nil, "", err
    			}
    		}
    		pvName, pvcUID := pvc.Spec.VolumeName, pvc.UID
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumebinding/binder.go

    		return true, nil, nil
    	}
    
    	bound, pvc, err = b.isPVCBound(logger, pod.Namespace, pvcName)
    	// ... the PVC must be owned by the pod.
    	if isEphemeral && err == nil && pvc != nil {
    		if err := ephemeral.VolumeIsForPod(pod, pvc); err != nil {
    			return false, nil, err
    		}
    	}
    	return
    }
    
    func (b *volumeBinder) isPVCBound(logger klog.Logger, namespace, pvcName string) (bool, *v1.PersistentVolumeClaim, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
Back to top