Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetVolumesToAttach (0.17 sec)

  1. pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go

    	// Assert
    	if volumeExists {
    		t.Fatalf("Volume %q exists, it should not.", volumeName)
    	}
    
    	volumesToAttach := dsw.GetVolumesToAttach()
    	if len(volumesToAttach) != 0 {
    		t.Fatalf("len(volumesToAttach) Expected: <0> Actual: <%v>", len(volumesToAttach))
    	}
    }
    
    // Calls GetVolumesToAttach()
    // Verifies zero volumes to attach.
    func Test_GetVolumesToAttach_Positive_NoNodes(t *testing.T) {
    	// Arrange
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  2. pkg/controller/volume/attachdetach/cache/desired_state_of_world.go

    	// the attach detach controller.
    	VolumeExists(volumeName v1.UniqueVolumeName, nodeName k8stypes.NodeName) bool
    
    	// GetVolumesToAttach generates and returns a list of volumes to attach
    	// and the nodes they should be attached to based on the current desired
    	// state of the world.
    	GetVolumesToAttach() []VolumeToAttach
    
    	// GetPodToAdd generates and returns a map of pods based on the current desired
    	// state of world
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/metrics/metrics.go

    		}
    	}
    	return nodeVolumeMap
    }
    
    func (collector *attachDetachStateCollector) getTotalVolumesCount() volumeCount {
    	stateVolumeMap := make(volumeCount)
    	for _, v := range collector.dsw.GetVolumesToAttach() {
    		if plugin, err := collector.volumePluginMgr.FindPluginBySpec(v.VolumeSpec); err == nil {
    			pluginName := pluginNameNotAvailable
    			if plugin != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 10 06:30:05 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  4. 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.
    		// The result is returned from CSIDriverLister which is from local cache. So this is not an expensive call.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/reconciler/reconciler.go

    	}
    }
    
    func (rc *reconciler) attachDesiredVolumes(logger klog.Logger) {
    	// Ensure volumes that should be attached are attached.
    	for _, volumeToAttach := range rc.desiredStateOfWorld.GetVolumesToAttach() {
    		if util.IsMultiAttachAllowed(volumeToAttach.VolumeSpec) {
    			// Don't even try to start an operation if there is already one running for the given volume and node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    				if err != nil {
    					t.Fatalf("Error adding pod %s to DSW: %s", podName, err)
    				}
    			}
    		}
    		// Act
    		logger, _ := ktesting.NewTestContext(t)
    		volumes := dsw.GetVolumesToAttach()
    		for _, vol := range volumes {
    			if vol.NodeName == "node1" {
    				rc.(*reconciler).reportMultiAttachError(logger, vol, nodes)
    			}
    		}
    
    		// Assert
    		close(fakeRecorder.Events)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
Back to top