- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for NewPV (0.17 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/registry/core/persistentvolume/strategy.go
newPv.Status.LastPhaseTransitionTime = oldPv.Status.LastPhaseTransitionTime case oldPv.Status.Phase != newPv.Status.Phase && (newPv.Status.LastPhaseTransitionTime == nil || newPv.Status.LastPhaseTransitionTime.Equal(oldPv.Status.LastPhaseTransitionTime)): // phase changed and client didn't set or didn't change the transition time now := NowFunc() newPv.Status.LastPhaseTransitionTime = &now } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 03:58:36 UTC 2023 - 7.6K 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/volume/util/resize_util.go
func PatchPV( oldPV *v1.PersistentVolume, newPV *v1.PersistentVolume, kubeClient clientset.Interface) (*v1.PersistentVolume, error) { oldData, err := json.Marshal(oldPV) if err != nil { return oldPV, fmt.Errorf("unexpected error marshaling old PV %q with error : %v", oldPV.Name, err) } newData, err := json.Marshal(newPV) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K 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/controller/volume/attachdetach/testing/testvolumespec.go
PersistentVolumeName: &pvName, }, }, Status: storagev1.VolumeAttachmentStatus{ Attached: status, }, } } // Returns a persistentVolume object func NewPV(pvName, volumeName string) *v1.PersistentVolume { return &v1.PersistentVolume{ ObjectMeta: metav1.ObjectMeta{ UID: types.UID(pvName), Name: pvName, }, Spec: v1.PersistentVolumeSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K 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 (0)