- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewPV (0.05 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/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/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)