- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 295 for pvcs (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)