- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 36 for AttachedVolume (0.21 sec)
-
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/kubelet/volume_host.go
} attachedVolumes := node.Status.VolumesAttached result := map[v1.UniqueVolumeName]string{} for i := range attachedVolumes { attachedVolume := attachedVolumes[i] result[attachedVolume.Name] = attachedVolume.DevicePath } return result, nil } func (kvh *kubeletVolumeHost) GetNodeName() types.NodeName { return kvh.kubelet.nodeName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
if !needsUpdate { return nil } return nsu.processNodeVolumes(logger, nodeName, attachedVolumes) } func (nsu *nodeStatusUpdater) processNodeVolumes(logger klog.Logger, nodeName types.NodeName, attachedVolumes []v1.AttachedVolume) error { nodeObj, err := nsu.nodeLister.Get(string(nodeName)) if errors.IsNotFound(err) { // If node does not exist, its status cannot be updated. // Do nothing so that there is no retry until node is created.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) } for _, attachedVolume := range node.Status.VolumesAttached { if attachedVolume.Name == volumeToMount.VolumeName { addVolumeNodeErr := actualStateOfWorld.MarkVolumeAsAttached( logger, v1.UniqueVolumeName(""), volumeToMount.VolumeSpec, nodeName, attachedVolume.DevicePath)
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/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/controller/volume/attachdetach/cache/actual_state_of_world_test.go
t *testing.T, attachedVolumes []AttachedVolume, expectedVolumeName v1.UniqueVolumeName, expectedVolumeSpecName string, expectedNodeName types.NodeName, expectedDevicePath string, expectedMountedByNode, expectNonZeroDetachRequestedTime bool) { for _, attachedVolume := range attachedVolumes { if attachedVolume.VolumeName == expectedVolumeName && attachedVolume.VolumeSpec.Name() == expectedVolumeSpecName &&
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/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) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
outerName := filepath.Base(tc.volumePath) pod, pv, pvc := getPodPVCAndPV(tc.volumeMode, "pod1", outerName, "pvc1") volumeSpec := &volume.Spec{PersistentVolume: pv} kubeClient := createtestClientWithPVPVC(pv, pvc, v1.AttachedVolume{ Name: v1.UniqueVolumeName(fmt.Sprintf("fake-plugin/%s", outerName)), DevicePath: "fake/path", }) rc, fakePlugin := getReconciler(tmpKubeletDir, t, mountPaths, kubeClient /*custom kubeclient*/)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
}, }, }) node = &nodes.Items[len(nodes.Items)-1] } uniqueVolumeName := v1.UniqueVolumeName(TestPluginName + "/" + volumeName) volumeAttached := v1.AttachedVolume{ Name: uniqueVolumeName, DevicePath: "fake/path", } node.Status.VolumesAttached = append(node.Status.VolumesAttached, volumeAttached) if inUse {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0)