- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for volume_attach (0.17 sec)
-
pkg/volume/util/operationexecutor/operation_generator.go
volumeToAttach.VolumeSpec, volumeToAttach.NodeName) if attachErr != nil { uncertainNode := volumeToAttach.NodeName if derr, ok := attachErr.(*volerr.DanglingAttachError); ok { uncertainNode = derr.CurrentNode } addErr := actualStateOfWorld.MarkVolumeAsUncertain( logger, volumeToAttach.VolumeName, volumeToAttach.VolumeSpec, uncertainNode)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
// attached to this node. The key in the map is the name of the volume and // the value is a volumeToAttach object containing more information about the volume. volumesToAttach map[v1.UniqueVolumeName]volumeToAttach } // The volumeToAttach object represents a volume that should be attached to a node. type volumeToAttach struct {
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/volume/util/operationexecutor/operation_executor_test.go
t.Parallel() // Arrange ch, quit, oe := setup() volumesToAttach := make([]VolumeToAttach, numVolumesToAttach) pdName := "pd-volume" // Act for i := range volumesToAttach { volumesToAttach[i] = VolumeToAttach{ VolumeName: v1.UniqueVolumeName(pdName), NodeName: "node", VolumeSpec: &volume.Spec{ PersistentVolume: &v1.PersistentVolume{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/fakegenerator.go
return f.recordFuncCall("GenerateUnmountVolumeFunc"), nil } func (f *fakeOGCounter) GenerateAttachVolumeFunc(logger klog.Logger, volumeToAttach VolumeToAttach, actualStateOfWorld ActualStateOfWorldAttacherUpdater) volumetypes.GeneratedOperations { return f.recordFuncCall("GenerateAttachVolumeFunc") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
func (oe *operationExecutor) AttachVolume( logger klog.Logger, volumeToAttach VolumeToAttach, actualStateOfWorld ActualStateOfWorldAttacherUpdater) error { generatedOperations := oe.operationGenerator.GenerateAttachVolumeFunc(logger, volumeToAttach, actualStateOfWorld) if util.IsMultiAttachAllowed(volumeToAttach.VolumeSpec) { return oe.pendingOperations.Run(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
// so attach it volumeToAttach := operationexecutor.VolumeToAttach{ VolumeName: volumeToMount.VolumeName, VolumeSpec: volumeToMount.VolumeSpec, NodeName: rc.nodeName, } klog.V(5).InfoS(volumeToAttach.GenerateMsgDetailed("Starting operationExecutor.AttachVolume", ""), "pod", klog.KObj(volumeToMount.Pod)) err := rc.operationExecutor.AttachVolume(logger, volumeToAttach, rc.actualStateOfWorld)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
func verifyVolumeToAttach( t *testing.T, volumesToAttach []VolumeToAttach, expectedNodeName k8stypes.NodeName, expectedVolumeName v1.UniqueVolumeName, expectedVolumeSpecName string) { for _, volumeToAttach := range volumesToAttach { if volumeToAttach.NodeName == expectedNodeName && volumeToAttach.VolumeName == expectedVolumeName && volumeToAttach.VolumeSpec.Name() == expectedVolumeSpecName { return }
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/reconciler/reconciler_test.go
t *testing.T, attachedNode k8stypes.NodeName, dsow cache.DesiredStateOfWorld) { multAttachCheckFunc := func() (bool, error) { for _, volumeToAttach := range dsow.GetVolumesToAttach() { if volumeToAttach.NodeName != attachedNode { if volumeToAttach.MultiAttachErrorReported { return true, nil } } } t.Logf("Warning: MultiAttach error not yet set on Node. Will retry.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0)