Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for attachability (0.21 sec)

  1. pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go

    		dswp.desiredStateOfWorld.DeletePod(dswPodUID, dswPodToAdd.VolumeName, dswPodToAdd.NodeName)
    	}
    
    	// check if the existing volumes changes its attachability
    	for _, volumeToAttach := range dswp.desiredStateOfWorld.GetVolumesToAttach() {
    		// IsAttachableVolume() will result in a fetch of CSIDriver object if the volume plugin type is CSI.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  2. pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go

    	if !volumeExists {
    		t.Fatalf(
    			"VolumeExists(%q) failed. Expected: <true> Actual: <%v>",
    			expectedVolumeName,
    			volumeExists)
    	}
    
    	// Change the CSI volume plugin attachability
    	fakeVolumePlugin.NonAttachable = true
    
    	dswp.findAndRemoveDeletedPods(logger)
    
    	// The volume should not exist after it becomes non-attachable
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    				if found {
    					return fmt.Errorf("found unexpected volume in reconstructed map")
    				}
    				return nil
    			},
    		},
    		{
    			name: "uncertain attachability is resolved to attachable",
    			opCallback: func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error {
    				asw.UpdateReconstructedVolumeAttachability(volumeOpts.VolumeName, true)
    				return nil
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    	// been fixed by such an update.
    	UpdateReconstructedDevicePath(volumeName v1.UniqueVolumeName, devicePath string)
    
    	// UpdateReconstructedVolumeAttachability updates volume attachability from the API server.
    	UpdateReconstructedVolumeAttachability(volumeName v1.UniqueVolumeName, volumeAttachable bool)
    }
    
    // MountedVolume represents a volume that has successfully been mounted to a pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go

    		podsFromCache[volumetypes.UniquePodName(volumeToMount.Pod.UID)] = struct{}{}
    		pod, podExists := dswp.podManager.GetPodByUID(volumeToMount.Pod.UID)
    		if podExists {
    
    			// check if the attachability has changed for this volume
    			if volumeToMount.PluginIsAttachable {
    				attachableVolumePlugin, err := dswp.volumePluginMgr.FindAttachablePluginBySpec(volumeToMount.VolumeSpec)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  6. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    	for _, vol := range attachedVolumes {
    		if vol.VolumeName == volumeName1 {
    			// devicePath + attachability must have been updated from node.status
    			assert.True(t, vol.PluginIsAttachable)
    			assert.Equal(t, vol.DevicePath, "fake/path")
    		}
    		if vol.VolumeName == volumeName2 {
    			// only attachability was updated from node.status
    			assert.False(t, vol.PluginIsAttachable)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/cache/desired_state_of_world.go

    	PopPodErrors(podName types.UniquePodName) []string
    
    	// GetPodsWithErrors returns names of pods that have stored errors.
    	GetPodsWithErrors() []types.UniquePodName
    
    	// MarkVolumeAttachability updates the volume's attachability for a given volume
    	MarkVolumeAttachability(volumeName v1.UniqueVolumeName, attachable bool)
    
    	// UpdatePersistentVolumeSize updates persistentVolumeSize in desired state of the world
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 27.1K bytes
    - Viewed (0)
Back to top