- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for GetVolumesToAttach (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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)