- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for NewUnmounter (0.23 sec)
-
pkg/volume/downwardapi/downwardapi.go
} return &downwardAPIVolumeMounter{ downwardAPIVolume: v, source: *spec.Volume.DownwardAPI, opts: &opts, }, nil } func (plugin *downwardAPIPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &downwardAPIVolumeUnmounter{ &downwardAPIVolume{ volName: volName, podUID: podUID, plugin: plugin,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/volume/configmap/configmap.go
}, source: *spec.Volume.ConfigMap, pod: *pod, opts: &opts, getConfigMap: plugin.getConfigMap, }, nil } func (plugin *configMapPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &configMapVolumeUnmounter{ &configMapVolume{ volName, podUID, plugin, plugin.host.GetMounter(plugin.GetPluginName()),
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
}, source: *spec.Volume.Projected, pod: pod, opts: &opts, }, nil } func (plugin *projectedPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &projectedVolumeUnmounter{ &projectedVolume{ volName: volName, podUID: podUID, plugin: plugin,
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/portworx/portworx.go
}, fsType: fsType, readOnly: readOnly, diskMounter: util.NewSafeFormatAndMountFromHost(plugin.GetPluginName(), plugin.host)}, nil } func (plugin *portworxVolumePlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return plugin.newUnmounterInternal(volName, podUID, plugin.util, plugin.host.GetMounter(plugin.GetPluginName())) }
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/volume/testing/volume_host.go
if spec.Volume != nil { spec.Volume.Name = wrapperVolumeName } plug, err := f.pluginMgr.FindPluginBySpec(&spec) if err != nil { return nil, err } return plug.NewUnmounter(spec.Name(), podUID) } // Returns the hostname of the host kubelet is running on func (f *fakeVolumeHost) GetHostName() string { return "fakeHostName" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
readOnly: readOnly, mounter: plugin.host.GetMounter(plugin.GetPluginName()), hu: kvh.GetHostUtil(), noTypeChecker: plugin.noTypeChecker, }, nil } func (plugin *hostPathPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &hostPathUnmounter{&hostPath{ path: "", }}, nil } // Recycle recycles/scrubs clean a HostPath volume.
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/fc/fc.go
return nil, fmt.Errorf("failed to get device path: %v", err) } mapper.MetricsProvider = volume.NewMetricsBlock(filepath.Join(blockPath, string(podUID))) return mapper, nil } func (plugin *fcPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { // Inject real implementations here, test through the internal function.
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/plugins.go
// - pod: The enclosing pod NewMounter(spec *Spec, podRef *v1.Pod, opts VolumeOptions) (Mounter, error) // NewUnmounter creates a new volume.Unmounter from recoverable state. // - name: The volume name, as per the v1.Volume spec. // - podUID: The UID of the enclosing pod NewUnmounter(name string, podUID types.UID) (Unmounter, error) // ConstructVolumeSpec constructs a volume spec based on the given volume name
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
mountDetector: mountDetector, plugin: plugin, MetricsProvider: volume.NewMetricsDu(getPath(pod.UID, spec.Name(), plugin.host)), }, nil } func (plugin *emptyDirPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { // Inject real implementations here, test through the internal function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
return nil, fmt.Errorf("failed to get device path: %v", err) } mapper.MetricsProvider = volume.NewMetricsBlock(filepath.Join(blockPath, string(podUID))) return mapper, nil } func (plugin *iscsiPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return plugin.newUnmounterInternal(volName, podUID, &ISCSIUtil{}, plugin.host.GetMounter(plugin.GetPluginName()), plugin.host.GetExec(plugin.GetPluginName())) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0)