- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for podVolumes (0.18 sec)
-
pkg/kubelet/kubelet_volumes.go
func (kl *Kubelet) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool) { volumesToReturn := make(map[string]volume.Volume) podVolumes := kl.volumeManager.GetMountedVolumesForPod( volumetypes.UniquePodName(podUID)) for outerVolumeSpecName, volume := range podVolumes { // TODO: volume.Mounter could be nil if volume object is recovered // from reconciler's sync state process. PR 33616 will fix this problem
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
InnerVolumeSpecName: mountedVolume.InnerVolumeSpecName, } } return podVolumes } func (vm *volumeManager) GetPossiblyMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap { podVolumes := make(container.VolumeMap) for _, mountedVolume := range vm.actualStateOfWorld.GetPossiblyMountedVolumesForPod(podName) { podVolumes[mountedVolume.OuterVolumeSpecName] = container.VolumeInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator_test.go
vol2 = "vol2" vol3 = "vol3" pvcClaimName0 = "pvc-fake0" pvcClaimName1 = "pvc-fake1" ) var ( ErrorWatchTimeout = errors.New("watch event timeout") // Create pod spec to test against podVolumes = []k8sv1.Volume{ { Name: vol0, VolumeSource: k8sv1.VolumeSource{ GCEPersistentDisk: &k8sv1.GCEPersistentDiskVolumeSource{ PDName: "fake-device1", }, }, }, { Name: vol1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
volumeManager kubeletvolume.VolumeManager, pod *v1.Pod) error { var podVolumes kubecontainer.VolumeMap err := retryWithExponentialBackOff( time.Duration(50*time.Millisecond), func() (bool, error) { // Verify volumes detached podVolumes = volumeManager.GetMountedVolumesForPod( util.GetUniquePodName(pod)) if len(podVolumes) != 0 { return false, nil } return true, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
return activePods } // makeBlockVolumes maps the raw block devices specified in the path of the container // Experimental func (kl *Kubelet) makeBlockVolumes(pod *v1.Pod, container *v1.Container, podVolumes kubecontainer.VolumeMap, blkutil volumepathhandler.BlockVolumePathHandler) ([]kubecontainer.DeviceInfo, error) { var devices []kubecontainer.DeviceInfo for _, device := range container.VolumeDevices {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
for _, podVolume := range pod.Spec.Volumes { if !mounts.Has(podVolume.Name) && !devices.Has(podVolume.Name) { // Volume is not used in the pod, ignore it. klog.V(4).InfoS("Skipping unused volume", "pod", klog.KObj(pod), "volumeName", podVolume.Name) continue } pvc, volumeSpec, volumeGidValue, err := dswp.createVolumeSpec(podVolume, pod, mounts, devices) if err != nil {
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/controller/volume/common/common.go
if !ok { return []string{}, nil } keys := []string{} for _, podVolume := range pod.Spec.Volumes { claimName := "" if pvcSource := podVolume.VolumeSource.PersistentVolumeClaim; pvcSource != nil { claimName = pvcSource.ClaimName } else if podVolume.VolumeSource.Ephemeral != nil { claimName = ephemeral.VolumeClaimName(pod, &podVolume) } if claimName != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 11 18:54:20 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
claimName = pvcSource.ClaimName readOnly = pvcSource.ReadOnly } isEphemeral := podVolume.VolumeSource.Ephemeral != nil if isEphemeral { claimName = ephemeral.VolumeClaimName(pod, &podVolume) } if claimName != "" { logger.V(10).Info("Found PVC", "PVC", klog.KRef(pod.Namespace, claimName)) // If podVolume is a PVC, fetch the real PV behind the claim pvc, err := getPVCFromCache(pod.Namespace, claimName, pvcLister)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
} defaultVolume := podVolume{ podName: "pod1uid", volumeSpecName: "volume-name", volumePath: "", pluginName: "fake-plugin", volumeMode: v1.PersistentVolumeFilesystem, } tests := []struct { name string podInfos []podInfo volumesFailedReconstruction []podVolume expectedUnmounts int }{ {
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/controller/volume/attachdetach/metrics/metrics.go
for _, pod := range pods { if len(pod.Spec.Volumes) <= 0 { continue } if pod.Spec.NodeName == "" { continue } for _, podVolume := range pod.Spec.Volumes { volumeSpec, err := util.CreateVolumeSpec(logger, podVolume, pod, types.NodeName(pod.Spec.NodeName), collector.volumePluginMgr, collector.pvcLister, collector.pvLister, collector.csiMigratedPluginManager, collector.intreeToCSITranslator)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 10 06:30:05 UTC 2023 - 7.5K bytes - Viewed (0)