- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getSourceFromSpec (0.27 sec)
-
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) -
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) -
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 (1)