- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 405 for volumeName (0.46 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
// Arrange grm := NewNestedPendingOperations(false /* exponentialBackOffOnError */) volume1Name := v1.UniqueVolumeName("volume1-name") volume2Name := v1.UniqueVolumeName("volume2-name") // Act err1 := grm.Run(volume1Name, EmptyUniquePodName, EmptyNodeName, volumetypes.GeneratedOperations{OperationFunc: noopFunc}) err2 := grm.Run(volume2Name, EmptyUniquePodName, EmptyNodeName, volumetypes.GeneratedOperations{OperationFunc: noopFunc})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
volumeName := v1.UniqueVolumeName("volume-name") volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName) nodeName := k8stypes.NodeName("node-name") dsw.AddNode(nodeName) volumeExists := dsw.VolumeExists(volumeName, nodeName) if volumeExists { t.Fatalf( "Volume %q/node %q should not exist, but it does.", volumeName, nodeName) } // Act
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/actual_state_of_world_test.go
asw := NewActualStateOfWorld(volumePluginMgr) volumeName := v1.UniqueVolumeName("volume-name") volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName) nodeName := types.NodeName("node-name") devicePath := "fake/device/path" // Act logger, _ := ktesting.NewTestContext(t) generatedVolumeName, err := asw.AddVolumeNode(logger, volumeName, volumeSpec, nodeName, devicePath, true) // Assert
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
nodeToUpdate.volumesToReportAsAttached[volumeName] if !nodeToUpdateVolumeExists { nodeToUpdate.statusUpdateNeeded = true nodeToUpdate.volumesToReportAsAttached[volumeName] = volumeName asw.nodesToUpdateStatusFor[nodeName] = nodeToUpdate logger.V(4).Info("Report volume as attached to node", "node", klog.KRef("", string(nodeName)), "volumeName", volumeName) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
type volumeNotAttachedError struct { volumeName v1.UniqueVolumeName } func (err volumeNotAttachedError) Error() string { return fmt.Sprintf( "volumeName %q does not exist in the list of attached volumes", err.volumeName) } func newVolumeNotAttachedError(volumeName v1.UniqueVolumeName) error { return volumeNotAttachedError{ volumeName: volumeName, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
close(stoppedChan) }() waitForVolumeToExistInASW(t, volumeName, asw) if tc.volumeName == volumetesting.TimeoutAndFailOnMountDeviceVolumeName { // Wait upto 10s for reconciler to catch up time.Sleep(reconcilerSyncWaitDuration) } if tc.volumeName == volumetesting.SuccessAndFailOnMountDeviceName || tc.volumeName == volumetesting.SuccessAndTimeoutDeviceName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
podName := "pod-uid" volumeName := v1.UniqueVolumeName("volume-name") volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName) nodeName := k8stypes.NodeName("node-name") dsw.AddNode(nodeName) volumeExists := dsw.VolumeExists(volumeName, nodeName) if volumeExists { t.Fatalf( "Volume %q/node %q should not exist, but it does.", volumeName, nodeName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
"volumeName", attachedVolume.VolumeName) } else { metrics.RecordForcedDetachMetric(metrics.ForceDetachReasonOutOfService) logger.Info("attacherDetacher.DetachVolume started: node has out-of-service taint, force detaching", "node", klog.KRef("", string(attachedVolume.NodeName)), "volumeName", attachedVolume.VolumeName) } } } if err != nil {
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/kubelet/volumemanager/reconciler/reconstruct.go
klog.ErrorS(err, "Could not find device mount path for volume", "volumeName", gvl.volumeName) continue } err = rc.actualStateOfWorld.MarkDeviceAsUncertain(gvl.volumeName, gvl.devicePath, deviceMountPath, seLinuxMountContext) if err != nil { klog.ErrorS(err, "Could not mark device is uncertain to actual state of world", "volumeName", gvl.volumeName, "deviceMountPath", deviceMountPath) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
// - volumeName exists, podName empty, nodeName empty // This key matches all other keys with the same volumeName. // - volumeName exists, podName exists, nodeName empty // This key matches with: // - the same volumeName and podName // - the same volumeName, but empty podName // - volumeName exists, podName empty, nodeName exists // This key matches with: // - the same volumeName and nodeName
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0)