Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 295 for pvcs (0.07 sec)

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

    		Controller:         &isController,
    		BlockOwnerDeletion: &isTrue,
    	}
    }
    
    func sortPVCs(pvcs []v1.PersistentVolumeClaim) []v1.PersistentVolumeClaim {
    	sort.Slice(pvcs, func(i, j int) bool {
    		return pvcs[i].Namespace < pvcs[j].Namespace ||
    			pvcs[i].Name < pvcs[j].Name
    	})
    	return pvcs
    }
    
    func createTestClient(objects ...runtime.Object) *fake.Clientset {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumebinding/binder.go

    		} else {
    			logger.V(5).Info("PVC is not bound", "PVC", klog.KObj(pvc))
    		}
    	}
    	return fullyBound, pvc, nil
    }
    
    func (b *volumeBinder) isPVCFullyBound(pvc *v1.PersistentVolumeClaim) bool {
    	return pvc.Spec.VolumeName != "" && metav1.HasAnnotation(pvc.ObjectMeta, volume.AnnBindCompleted)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    			delayFunc: func(t *testing.T, ctx context.Context, testEnv *testEnv, pod *v1.Pod, pvs []*v1.PersistentVolume, pvcs []*v1.PersistentVolumeClaim) {
    				pvc := pvcs[0]
    				// Delete PVC will fail check
    				if err := testEnv.client.CoreV1().PersistentVolumeClaims(pvc.Namespace).Delete(ctx, pvc.Name, metav1.DeleteOptions{}); err != nil {
    					t.Errorf("failed to delete PVC %q: %v", pvc.Name, err)
    				}
    			},
    			shouldFail: true,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    }
    
    // calPreFilterState computes preFilterState describing which PVCs use ReadWriteOncePod
    // and which pods in the cluster are in conflict.
    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) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  5. pkg/volume/util/finalizer.go

    limitations under the License.
    */
    
    package util
    
    const (
    	// PVCProtectionFinalizer is the name of finalizer on PVCs that have a running pod.
    	PVCProtectionFinalizer = "kubernetes.io/pvc-protection"
    
    	// PVProtectionFinalizer is the name of finalizer on PVs that are bound by PVCs
    	PVProtectionFinalizer = "kubernetes.io/pv-protection"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 10 21:24:35 UTC 2018
    - 874 bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go

    	// deletedPVPod2 is a different pod than deletedPVPod but using the same PVC
    	deletedPVPod2       = st.MakePod().PVC("pvcWithDeletedPV").Obj()
    	anotherDeletedPVPod = st.MakePod().PVC("anotherPVCWithDeletedPV").Obj()
    	emptyPod            = st.MakePod().Obj()
    	unboundPVCPod       = st.MakePod().PVC("unboundPVC").Obj()
    	// Different pod than unboundPVCPod, but using the same unbound PVC
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 36.8K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			pod:  makePod("pod-a").withPVCVolume("pvc-a", "volume-a").withPVCVolume("pvc-b", "volume-b").Pod,
    			nodes: []*v1.Node{
    				makeNode("node-a").Node,
    			},
    			pvcs: []*v1.PersistentVolumeClaim{
    				makePVC("pvc-a", waitSC.Name).withBoundPV("pv-a").PersistentVolumeClaim,
    				makePVC("pvc-b", waitSC.Name).withBoundPV("pv-b").PersistentVolumeClaim,
    			},
    			pvs: []*v1.PersistentVolume{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
  8. pkg/scheduler/testing/framework/fake_listers.go

    type persistentVolumeClaimNamespaceLister struct {
    	pvcs      []*v1.PersistentVolumeClaim
    	namespace string
    }
    
    func (f *persistentVolumeClaimNamespaceLister) Get(name string) (*v1.PersistentVolumeClaim, error) {
    	for _, pvc := range f.pvcs {
    		if pvc.Name == name && pvc.Namespace == f.namespace {
    			return pvc, nil
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 20 10:14:08 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  9. pkg/controller/statefulset/stateful_pod_control.go

    				return err
    			}
    		}
    		if utilfeature.DefaultFeatureGate.Enabled(features.StatefulSetAutoDeletePVC) {
    			// if the Pod's PVCs are not consistent with the StatefulSet's PVC deletion policy, update the PVC
    			// and dirty the pod.
    			if match, err := spc.ClaimsMatchRetentionPolicy(ctx, set, pod); err != nil {
    				spc.recordPodEvent("update", set, pod, err)
    				return err
    			} else if !match {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  10. plugin/pkg/admission/storage/persistentvolume/resize/admission.go

    		return admission.NewForbidden(a, fmt.Errorf("only dynamically provisioned pvc can be resized and "+
    			"the storageclass that provisions the pvc must support resize"))
    	}
    
    	return nil
    }
    
    // Growing Persistent volumes is only allowed for PVCs for which their StorageClass
    // explicitly allows it.
    func (pvcr *persistentVolumeClaimResize) allowResize(pvc, oldPvc *api.PersistentVolumeClaim) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 20 15:11:00 UTC 2019
    - 3.9K bytes
    - Viewed (0)
Back to top