Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for waitforattach (0.37 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. staging/src/k8s.io/api/storage/v1alpha1/types_swagger_doc_generated.go

    	"attachmentMetadata": "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.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 03:26:35 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/storage/v1alpha1/types.go

    	// 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
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 27 20:06:32 UTC 2023
    - 13.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/storage/v1beta1/types_swagger_doc_generated.go

    	"attachmentMetadata": "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.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 09:18:43 UTC 2023
    - 23.4K bytes
    - Viewed (0)
Back to top