Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getSourceFromSpec (0.49 sec)

  1. pkg/volume/csi/csi_util.go

    		return false
    	}
    	for _, mode := range modes {
    		if mode == api.ReadWriteOnce {
    			return true
    		}
    	}
    	return false
    }
    
    // getSourceFromSpec returns either CSIVolumeSource or CSIPersistentVolumeSource, but not both
    func getSourceFromSpec(spec *volume.Spec) (*api.CSIVolumeSource, *api.CSIPersistentVolumeSource, error) {
    	if spec == nil {
    		return nil, nil, fmt.Errorf("volume.Spec nil")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 28 17:14:00 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_plugin.go

    	}
    	return *csiDriver.Spec.RequiresRepublish
    }
    
    func (p *csiPlugin) NewMounter(
    	spec *volume.Spec,
    	pod *api.Pod,
    	_ volume.VolumeOptions) (volume.Mounter, error) {
    
    	volSrc, pvSrc, err := getSourceFromSpec(spec)
    	if err != nil {
    		return nil, err
    	}
    
    	var (
    		driverName   string
    		volumeHandle string
    		readOnly     bool
    	)
    
    	switch {
    	case volSrc != nil:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_mounter.go

    	}
    
    	ctx, cancel := createCSIOperationContext(c.spec, csiTimeout)
    	defer cancel()
    
    	volSrc, pvSrc, err := getSourceFromSpec(c.spec)
    	if err != nil {
    		return errors.New(log("mounter.SetupAt failed to get CSI persistent source: %v", err))
    	}
    
    	// Check CSIDriver.Spec.Mode to ensure that the CSI driver
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jan 30 10:47:59 UTC 2024
    - 21K bytes
    - Viewed (0)
Back to top