- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewPV (0.08 sec)
-
pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go
t.Fatalf("failed to get PV: %v", err) } // Assume PV newPV := pv.DeepCopy() newPV.Spec.ClaimRef = &v1.ObjectReference{Name: "test-claim"} if err := cache.Assume(newPV); err != nil { t.Fatalf("failed to assume PV: %v", err) } if err := verifyPV(cache, pvName, newPV); err != nil { t.Fatalf("failed to get PV after assume: %v", err) } // Add old PV
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
} podInformer.GetIndexer().Add(newPod) } if tc.pvName != "" { var newPv *v1.PersistentVolume if tc.csiMigration { // NewPV returns a GCEPersistentDisk volume, which is migrated. newPv = controllervolumetesting.NewPV(tc.pvName, tc.volName) } else { // Otherwise use NFS, which is not subject to migration. newPv = controllervolumetesting.NewNFSPV(tc.pvName, tc.volName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
newBindings := []*BindingInfo{} for _, binding := range podVolumes.StaticBindings { newPV, dirty, err := volume.GetBindVolumeToClaim(binding.pv, binding.pvc) logger.V(5).Info("AssumePodVolumes: GetBindVolumeToClaim", "pod", klog.KObj(assumedPod), "PV", klog.KObj(binding.pv), "PVC", klog.KObj(binding.pvc), "newPV", klog.KObj(newPV), "dirty", dirty, ) if err != nil {
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/apis/core/validation/validation_test.go
newPV: testVolumeWithNodeAffinity(nil), }, } for name, scenario := range scenarios { originalNewPV := scenario.newPV.DeepCopy() originalOldPV := scenario.oldPV.DeepCopy() opts := ValidationOptionsForPersistentVolume(scenario.newPV, scenario.oldPV) errs := ValidatePersistentVolumeUpdate(scenario.newPV, scenario.oldPV, opts)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 857.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
newPVC := pvc.DeepCopy() newPVC.Annotations = map[string]string{} return newPVC } func pvRemoveClaimUID(pv *v1.PersistentVolume) *v1.PersistentVolume { newPV := pv.DeepCopy() newPV.Spec.ClaimRef.UID = "" return newPV } func makeCSINode(name, migratedPlugin string) *storagev1.CSINode { return &storagev1.CSINode{ ObjectMeta: metav1.ObjectMeta{ Name: name,
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/apis/core/validation/validation.go
(newPv.Spec.CSI != nil && newPv.Spec.CSI.ControllerExpandSecretRef != nil) { newPv = newPv.DeepCopy() newPv.Spec.CSI.ControllerExpandSecretRef = nil } // PersistentVolumeSource should be immutable after creation. if !apiequality.Semantic.DeepEqual(newPv.Spec.PersistentVolumeSource, oldPv.Spec.PersistentVolumeSource) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 349.5K bytes - Viewed (1)