Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for volumeManager (0.44 sec)

  1. pkg/kubelet/volumemanager/volume_manager.go

    	"k8s.io/kubernetes/pkg/kubelet/config"
    	"k8s.io/kubernetes/pkg/kubelet/container"
    	"k8s.io/kubernetes/pkg/kubelet/volumemanager/cache"
    	"k8s.io/kubernetes/pkg/kubelet/volumemanager/metrics"
    	"k8s.io/kubernetes/pkg/kubelet/volumemanager/populator"
    	"k8s.io/kubernetes/pkg/kubelet/volumemanager/reconciler"
    	"k8s.io/kubernetes/pkg/volume"
    	"k8s.io/kubernetes/pkg/volume/csimigration"
    	"k8s.io/kubernetes/pkg/volume/util"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/volume_manager_test.go

    		},
    	}
    	return node, pod, pv, claim
    }
    
    func simulateVolumeInUseUpdate(volumeName v1.UniqueVolumeName, stopCh <-chan struct{}, volumeManager VolumeManager) {
    	ticker := time.NewTicker(100 * time.Millisecond)
    	defer ticker.Stop()
    	for {
    		select {
    		case <-ticker.C:
    			volumeManager.MarkVolumesAsReportedInUse(
    				[]v1.UniqueVolumeName{volumeName})
    		case <-stopCh:
    			return
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  3. pkg/kubelet/runonce_test.go

    	if err != nil {
    		t.Fatalf("failed to initialize VolumePluginMgr: %v", err)
    	}
    	kb.volumeManager = volumemanager.NewVolumeManager(
    		true,
    		kb.nodeName,
    		kb.podManager,
    		kb.podWorkers,
    		kb.kubeClient,
    		kb.volumePluginMgr,
    		fakeRuntime,
    		kb.mounter,
    		kb.hostutil,
    		kb.getPodsDir(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. 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
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_node_status_test.go

    			// override test volumeManager
    			fakeVolumeManager := kubeletvolume.NewFakeVolumeManager(tc.existingVolumes)
    			kubelet.volumeManager = fakeVolumeManager
    
    			// Only test VolumesInUse setter
    			kubelet.setNodeStatusFuncs = []func(context.Context, *v1.Node) error{
    				nodestatus.VolumesInUse(kubelet.volumeManager.ReconcilerStatesHasBeenSynced,
    					kubelet.volumeManager.GetVolumesInUse),
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  6. pkg/kubelet/util/manager/watch_based_manager.go

    		// already immutable. However, given that:
    		// - we want to also handle the case when object is marked as immutable later
    		// - Secrets and ConfigMaps are periodically fetched by volumemanager anyway
    		// - doing that wouldn't provide visible scalability/performance gain - we
    		//   already have it from here
    		// - doing that would require significant refactoring to reflector
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_test.go

    			}
    		})
    	}
    }
    
    func waitForVolumeUnmount(
    	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))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_node_status.go

    			kl.containerManager.Status, kl.shutdownManager.ShutdownStatus, kl.recordNodeStatusEvent, kl.supportLocalStorageCapacityIsolation()),
    		nodestatus.VolumesInUse(kl.volumeManager.ReconcilerStatesHasBeenSynced, kl.volumeManager.GetVolumesInUse),
    		// TODO(mtaufen): I decided not to move this setter for now, since all it does is send an event
    		// and record state back to the Kubelet runtime object. In the future, I'd like to isolate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  9. pkg/kubelet/volumemanager/reconciler/reconstruct_common.go

    	v1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/kubelet/config"
    	"k8s.io/kubernetes/pkg/kubelet/volumemanager/metrics"
    	volumepkg "k8s.io/kubernetes/pkg/volume"
    	"k8s.io/kubernetes/pkg/volume/util"
    	"k8s.io/kubernetes/pkg/volume/util/operationexecutor"
    	volumetypes "k8s.io/kubernetes/pkg/volume/util/types"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet.go

    		// so that service name could be resolved
    		klet.dnsConfigurer.SetupDNSinContainerizedMounter(experimentalMounterPath)
    	}
    
    	// setup volumeManager
    	klet.volumeManager = volumemanager.NewVolumeManager(
    		kubeCfg.EnableControllerAttachDetach,
    		nodeName,
    		klet.podManager,
    		klet.podWorkers,
    		klet.kubeClient,
    		klet.volumePluginMgr,
    		klet.containerRuntime,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (1)
Back to top