- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for waitforattach (0.2 sec)
-
pkg/volume/volume.go
VolumesAreAttached(specs []*Spec, nodeName types.NodeName) (map[*Spec]bool, error) // WaitForAttach blocks until the device is attached to this // node. If it successfully attaches, the path to the device // is returned. Otherwise, if the device does not attach after // the given timeout period, an error will be returned. WaitForAttach(spec *Spec, devicePath string, pod *v1.Pod, timeout time.Duration) (string, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
devicePath, err = volAttacher.WaitForAttach(volSpec, "", pod, 500*time.Millisecond) if err != nil { t.Fatal("csiTest.VolumeAll attacher.WaitForAttach failed:", err) } if devicePath != attachName { t.Fatalf("csiTest.VolumeAll attacher.WaitForAttach got unexpected value %s", devicePath) } t.Log("csiTest.VolumeAll attacher.WaitForAttach succeeded OK, attachment ID:", devicePath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/volume/iscsi/attacher.go
volumesAttachedCheck := make(map[*volume.Spec]bool) for _, spec := range specs { volumesAttachedCheck[spec] = true } return volumesAttachedCheck, nil } func (attacher *iscsiAttacher) WaitForAttach(spec *volume.Spec, devicePath string, pod *v1.Pod, timeout time.Duration) (string, error) { mounter, err := volumeSpecToMounter(spec, attacher.host, attacher.targetLocks, pod) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:31 UTC 2022 - 6.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
if volumeAttacher != nil { // Wait for attachable volumes to finish attaching klog.InfoS(volumeToMount.GenerateMsgDetailed("MountVolume.WaitForAttach entering", fmt.Sprintf("DevicePath %q", volumeToMount.DevicePath)), "pod", klog.KObj(volumeToMount.Pod)) devicePath, err = volumeAttacher.WaitForAttach( volumeToMount.VolumeSpec, devicePath, volumeToMount.Pod, waitForAttachTimeout) if err != nil {
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/testing/testvolumespec.go
return nil, nil } func (attacher *testPluginAttacher) WaitForAttach(spec *volume.Spec, devicePath string, pod *v1.Pod, timeout time.Duration) (string, error) { attacher.pluginLock.Lock() defer attacher.pluginLock.Unlock() if spec == nil { *attacher.ErrorEncountered = true return "", fmt.Errorf("WaitForAttach called with nil volume spec") } fakePath := fmt.Sprintf("%s/%s", devicePath, spec.Name())
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/csi/csi_attacher.go
return "", nil } func (c *csiAttacher) WaitForAttach(spec *volume.Spec, _ string, pod *v1.Pod, timeout time.Duration) (string, error) { source, err := getPVSourceFromSpec(spec) if err != nil { return "", errors.New(log("attacher.WaitForAttach failed to extract CSI volume source: %v", err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
} wg.Wait() }) } } func TestAttacherWaitForVolumeAttachmentWithCSIDriver(t *testing.T) { // In order to detect if the volume plugin would skip WaitForAttach for non-attachable drivers, // we do not instantiate any VolumeAttachment. So if the plugin does not skip attach, WaitForVolumeAttachment // will return an error that volume attachment was not found. tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/volume/fc/attacher.go
volumesAttachedCheck := make(map[*volume.Spec]bool) for _, spec := range specs { volumesAttachedCheck[spec] = true } return volumesAttachedCheck, nil } func (attacher *fcAttacher) WaitForAttach(spec *volume.Spec, devicePath string, _ *v1.Pod, timeout time.Duration) (string, error) { mounter, err := volumeSpecToMounter(spec, attacher.host) if err != nil { klog.Warningf("failed to get fc mounter: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 31 12:02:51 UTC 2022 - 7.5K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1alpha1/generated.proto
optional bool attached = 1; // attachmentMetadata is populated with any // information returned by the attach operation, upon successful attach, that must be passed // into subsequent WaitForAttach or Mount calls. // This field must only be set by the entity completing the attach // operation, i.e. the external-attacher. // +optional map<string, string> attachmentMetadata = 2;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 9.4K bytes - Viewed (0) -
staging/src/k8s.io/api/storage/v1alpha1/generated.proto
optional bool attached = 1; // attachmentMetadata is populated with any // information returned by the attach operation, upon successful attach, that must be passed // into subsequent WaitForAttach or Mount calls. // This field must only be set by the entity completing the attach // operation, i.e. the external-attacher. // +optional map<string, string> attachmentMetadata = 2;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 11.3K bytes - Viewed (0)