- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for waitforattach (0.26 sec)
-
pkg/volume/flexvolume/attacher.go
return (*attacherDefaults)(a).Attach(spec, hostName) } else if err != nil { return "", err } return status.DevicePath, err } // WaitForAttach is part of the volume.Attacher interface func (a *flexVolumeAttacher) WaitForAttach(spec *volume.Spec, devicePath string, _ *v1.Pod, timeout time.Duration) (string, error) { call := a.plugin.NewDriverCallWithTimeout(waitForAttachCmd, timeout) call.Append(devicePath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 03 23:29:42 UTC 2021 - 3.6K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher-defaults.go
return "", nil } // WaitForAttach is part of the volume.Attacher interface func (a *attacherDefaults) WaitForAttach(spec *volume.Spec, devicePath string, timeout time.Duration) (string, error) { klog.Warning(logPrefix(a.plugin.flexVolumePlugin), "using default WaitForAttach for volume ", spec.Name(), ", device ", devicePath) return devicePath, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 2.4K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher_test.go
plugin, _ := testPlugin(t) plugin.runner = fakeRunner( assertDriverCall(t, notSupportedOutput(), waitForAttachCmd, "/dev/sdx", specJSON(plugin, spec, nil)), ) a, _ := plugin.NewAttacher() a.WaitForAttach(spec, "/dev/sdx", pod, 1*time.Second) } func TestMountDevice(tt *testing.T) { t := harness.For(tt) defer t.Close() spec := fakeVolumeSpec() plugin, rootDir := testPlugin(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 03 23:29:42 UTC 2021 - 2.2K 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/flexvolume/driver-call.go
) const ( // Driver calls initCmd = "init" getVolumeNameCmd = "getvolumename" isAttached = "isattached" attachCmd = "attach" waitForAttachCmd = "waitforattach" mountDeviceCmd = "mountdevice" detachCmd = "detach" unmountDeviceCmd = "unmountdevice" mountCmd = "mount" unmountCmd = "unmount" expandVolumeCmd = "expandvolume"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 25 02:39:55 UTC 2021 - 7.5K 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) -
pkg/volume/flexvolume/detacher-defaults.go
return nil } // WaitForDetach is part of the volume.Detacher interface. func (d *detacherDefaults) WaitForDetach(devicePath string, timeout time.Duration) error { klog.Warning(logPrefix(d.plugin.flexVolumePlugin), "using default WaitForDetach for device ", devicePath) return nil } // UnmountDevice is part of the volume.Detacher interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 1.6K bytes - Viewed (0)