- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 37 for PVName (0.11 sec)
-
pkg/volume/util/recyclerclient/recycler_client.go
// will be overwritten with unique name based on PV.Name. // client - kube client for API operations. func RecycleVolumeByWatchingPodUntilCompletion(pvName string, pod *v1.Pod, kubeClient clientset.Interface, recorder RecycleEventRecorder) error { return internalRecycleVolumeByWatchingPodUntilCompletion(pvName, pod, newRecyclerClient(kubeClient, recorder)) } // same as above func comments, except 'recyclerClient' is a narrower pod API
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (1) -
pkg/controller/volume/attachdetach/util/util.go
return nil, err } } pvName, pvcUID := pvc.Spec.VolumeName, pvc.UID logger.V(10).Info("Found bound PV for PVC", "PVC", klog.KRef(pod.Namespace, claimName), "pvcUID", pvcUID, "PV", klog.KRef("", pvName)) // Fetch actual PV object volumeSpec, err := getPVSpecFromCache( pvName, readOnly, pvcUID, pvLister) if err != nil { return nil, fmt.Errorf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
}}, nil } // Recycle recycles/scrubs clean an NFS volume. // Recycle blocks until the pod has completed or any error occurs. func (plugin *nfsPlugin) Recycle(pvName string, spec *volume.Spec, eventRecorder recyclerclient.RecycleEventRecorder) error { if spec.PersistentVolume == nil || spec.PersistentVolume.Spec.NFS == nil { return fmt.Errorf("spec.PersistentVolumeSource.NFS is nil") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
verifyTearDownCalls(fakePlugin, 0) }) } } func getPodPVCAndPV(volumeMode v1.PersistentVolumeMode, podName, pvName, pvcName string) (*v1.Pod, *v1.PersistentVolume, *v1.PersistentVolumeClaim) { pv := &v1.PersistentVolume{ ObjectMeta: metav1.ObjectMeta{ Name: pvName, UID: "pvuid", }, Spec: v1.PersistentVolumeSpec{ ClaimRef: &v1.ObjectReference{Name: pvcName}, VolumeMode: &volumeMode,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/test_utils.go
}, Spec: v1.PersistentVolumeClaimSpec{ StorageClassName: ptr.To(storageClassName), }, }} } func (pvcb pvcBuilder) withBoundPV(pvName string) pvcBuilder { pvcb.PersistentVolumeClaim.Spec.VolumeName = pvName metav1.SetMetaDataAnnotation(&pvcb.PersistentVolumeClaim.ObjectMeta, volume.AnnBindCompleted, "true") return pvcb }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 4.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
return nil, nil, "", err } } pvName, pvcUID := pvc.Spec.VolumeName, pvc.UID klog.V(5).InfoS("Found bound PV for PVC", "PVC", klog.KRef(pod.Namespace, pvcSource.ClaimName), "PVCUID", pvcUID, "PVName", pvName) // Fetch actual PV object volumeSpec, volumeGidValue, err := dswp.getPVSpec(pvName, pvcSource.ReadOnly, pvcUID) if err != nil { return nil, nil, "", fmt.Errorf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/registry/core/persistentvolume/storage/storage_test.go
t.Errorf("unexpected object: %s", cmp.Diff(pvIn.Status, pvOut.Status)) } } func getPhaseTranstitionTime(ctx context.Context, pvName string, storage *REST) (*metav1.Time, error) { obj, err := storage.Get(ctx, pvName, &metav1.GetOptions{}) if err != nil { return nil, err } return obj.(*api.PersistentVolume).Status.LastPhaseTransitionTime, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go
func makePVsWithZoneLabel(num int) []*v1.PersistentVolume { pvList := make([]*v1.PersistentVolume, num, num) for i := 0; i < len(pvList); i++ { pvName := fmt.Sprintf("Vol_Stable_%d", i) zone := fmt.Sprintf("us-west-%d", i) pvList[i] = &v1.PersistentVolume{ ObjectMeta: metav1.ObjectMeta{Name: pvName, Labels: map[string]string{v1.LabelTopologyZone: zone}}, } } return pvList }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 05:17:04 UTC 2023 - 20K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
// Recycle blocks until the pod has completed or any error occurs. // HostPath recycling only works in single node clusters and is meant for testing purposes only. func (plugin *hostPathPlugin) Recycle(pvName string, spec *volume.Spec, eventRecorder recyclerclient.RecycleEventRecorder) error { if spec.PersistentVolume == nil || spec.PersistentVolume.Spec.HostPath == nil { return fmt.Errorf("spec.PersistentVolume.Spec.HostPath is nil")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0)