- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 24 for NewSpecFromVolume (0.32 sec)
-
pkg/volume/csi/csi_mounter_test.go
fsType: "ext4", setupShouldFail: true, spec: func(fsType string, options []string) *volume.Spec { volSrc := makeTestVol("pv1", testDriver) volSrc.CSI.FSType = &fsType return volume.NewSpecFromVolume(volSrc) }, }, { name: "setup with persistent source", podUID: types.UID(fmt.Sprintf("%08X", rand.Uint64())), mode: storage.VolumeLifecyclePersistent, fsType: "zfs",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/volume/configmap/configmap.go
configMapVolume := &v1.Volume{ Name: volumeName, VolumeSource: v1.VolumeSource{ ConfigMap: &v1.ConfigMapVolumeSource{}, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(configMapVolume), }, nil } type configMapVolume struct { volName string podUID types.UID plugin *configMapPlugin mounter mount.Interface volume.MetricsProvider }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/projected/projected.go
projectedVolume := &v1.Volume{ Name: volumeName, VolumeSource: v1.VolumeSource{ Projected: &v1.ProjectedVolumeSource{}, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(projectedVolume), }, nil } type projectedVolume struct { volName string sources []v1.VolumeProjection podUID types.UID plugin *projectedPlugin volume.MetricsProvider }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo_test.go
allErrs = append(allErrs, fmt.Errorf("can't find the plugin by name")) return allErrs } pod := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}} mounter, err := plug.NewMounter(volume.NewSpecFromVolume(scenario.vol), pod, volume.VolumeOptions{}) if err != nil { allErrs = append(allErrs, fmt.Errorf("failed to make a new Mounter: %w", err)) return allErrs } if mounter == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 08:26:26 UTC 2024 - 12K bytes - Viewed (0) -
pkg/volume/portworx/portworx.go
Name: volumeName, VolumeSource: v1.VolumeSource{ PortworxVolume: &v1.PortworxVolumeSource{ VolumeID: volumeName, }, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(portworxVolume), }, nil } func (plugin *portworxVolumePlugin) SupportsMountOption() bool { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
} // Do not return the original volume object, since it's from the shared // informer it may be mutated by another consumer. clonedPodVolume := podVolume.DeepCopy() origspec := volume.NewSpecFromVolume(clonedPodVolume) spec, err := translateInTreeSpecToCSIIfNeeded(origspec, nodeName, vpm, csiMigratedPluginManager, csiTranslator, pod.Namespace) if err != nil { return nil, fmt.Errorf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{ PDName: "pdName", FSType: "ext4", ReadOnly: false, }, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(fakeVolume), }, nil } func (plugin *TestPlugin) NewAttacher() (volume.Attacher, error) { attacher := testPluginAttacher{ ErrorEncountered: &plugin.ErrorEncountered,
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/fc/fc.go
fcVolume.VolumeSource.FC.TargetWWNs, *fcVolume.VolumeSource.FC.Lun, fcVolume.VolumeSource.FC.WWIDs) return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(fcVolume), SELinuxMountContext: mountContext, }, nil } // ConstructBlockVolumeSpec creates a new volume.Spec with following steps.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
Name: volumeName, VolumeSource: v1.VolumeSource{ HostPath: &v1.HostPathVolumeSource{ Path: volumeName, }, }, } return volume.ReconstructedVolume{ Spec: volume.NewSpecFromVolume(hostPathVolume), }, nil } func newDeleter(spec *volume.Spec, host volume.VolumeHost) (volume.Deleter, error) { if spec.PersistentVolume != nil && spec.PersistentVolume.Spec.HostPath == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/volume/plugins.go
Spec *Spec // SELinuxMountContext is value of -o context=XYZ mount option. // If empty, no such mount option is used. SELinuxMountContext string } // NewSpecFromVolume creates an Spec from an v1.Volume func NewSpecFromVolume(vs *v1.Volume) *Spec { return &Spec{ Volume: vs, } } // NewSpecFromPersistentVolume creates an Spec from an v1.PersistentVolume
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0)