- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 37 for attachedVolumes (0.26 sec)
-
pkg/controller/volume/attachdetach/testing/testvolumespec.go
copy(ret[nodeName], volumeList) } return ret } func CreateTestPlugin() []volume.VolumePlugin { attachedVolumes := make(map[string][]string) detachedVolumes := make(map[string][]string) return []volume.VolumePlugin{&TestPlugin{ ErrorEncountered: false, attachedVolumeMap: attachedVolumes, detachedVolumeMap: detachedVolumes, pluginLock: &sync.RWMutex{}, }} } // Attacher
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
GenerateDetachVolumeFunc(logger klog.Logger, volumeToDetach AttachedVolume, verifySafeToDetach bool, actualStateOfWorld ActualStateOfWorldAttacherUpdater) (volumetypes.GeneratedOperations, error) // Generates the VolumesAreAttached function needed to verify if volume plugins are attached
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/attachedvolume.go
// with apply. type AttachedVolumeApplyConfiguration struct { Name *v1.UniqueVolumeName `json:"name,omitempty"` DevicePath *string `json:"devicePath,omitempty"` } // AttachedVolumeApplyConfiguration constructs an declarative configuration of the AttachedVolume type for use with // apply. func AttachedVolume() *AttachedVolumeApplyConfiguration {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
} return nil } func waitForVolumeDetach( volumeName v1.UniqueVolumeName, volumeManager kubeletvolume.VolumeManager) error { attachedVolumes := []v1.UniqueVolumeName{} err := retryWithExponentialBackOff( time.Duration(50*time.Millisecond), func() (bool, error) { // Verify volumes detached
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
if hasOutOfServiceTaint { logger.V(4).Info("node has out-of-service taint", "node", klog.KRef("", string(attachedVolume.NodeName))) } verifySafeToDetach := !(forceDetatchTimeoutExpired || hasOutOfServiceTaint) err = rc.attacherDetacher.DetachVolume(logger, attachedVolume.AttachedVolume, verifySafeToDetach, rc.actualStateOfWorld)
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/reconciler_common.go
klog.InfoS(attachedVolume.GenerateMsgDetailed("Volume detached", fmt.Sprintf("DevicePath %q", attachedVolume.DevicePath))) } else { // Only detach if kubelet detach is enabled klog.V(5).InfoS(attachedVolume.GenerateMsgDetailed("Starting operationExecutor.DetachVolume", "")) err := rc.operationExecutor.DetachVolume(
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/kubelet/volumemanager/reconciler/reconstruct.go
attachable := false for _, attachedVolume := range node.Status.VolumesAttached { if volumeID != attachedVolume.Name { continue } rc.actualStateOfWorld.UpdateReconstructedDevicePath(volumeID, attachedVolume.DevicePath) attachable = true klog.V(4).InfoS("Updated devicePath from node status for volume", "volumeName", attachedVolume.Name, "path", attachedVolume.DevicePath) }
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/controller/volume/attachdetach/attach_detach_controller_test.go
} inUse := inUseVolumes.Has(attachedVolume.Name) mounted := allAttachedVolumes[attachedVolume.Name].MountedByNode if mounted != inUse { t.Fatalf("Node %s, volume %s MountedByNode %v unexpected", nodeName, attachedVolume.Name, mounted) } } } pods, err := adc.podLister.List(labels.Everything()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
var devicePath string var found bool node, err := adc.nodeLister.Get(string(nodeName)) if err != nil { return devicePath, err } for _, attachedVolume := range node.Status.VolumesAttached { if volumeName == attachedVolume.Name { devicePath = attachedVolume.DevicePath found = true break } } if !found { err = fmt.Errorf("Volume %s not found on node %s", volumeName, nodeName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
func(action core.Action) (bool, runtime.Object, error) { return true, &v1.Node{ ObjectMeta: metav1.ObjectMeta{Name: testKubeletHostname}, Status: v1.NodeStatus{ VolumesAttached: []v1.AttachedVolume{ { Name: "fake/fake-device", DevicePath: "fake/path", }, }}, }, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0)