- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewWrapperUnmounter (0.29 sec)
-
pkg/controller/volume/persistentvolume/volume_host.go
return nil, fmt.Errorf("PersistentVolumeController.NewWrapperMounter is not implemented") } func (ctrl *PersistentVolumeController) NewWrapperUnmounter(volName string, spec vol.Spec, podUID types.UID) (vol.Unmounter, error) { return nil, fmt.Errorf("PersistentVolumeController.NewWrapperMounter is not implemented") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
return nil, fmt.Errorf("NewWrapperMounter not supported by expand controller's VolumeHost implementation") } func (expc *expandController) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) { return nil, fmt.Errorf("NewWrapperUnmounter not supported by expand controller's VolumeHost implementation") } func (expc *expandController) GetMounter(pluginName string) mount.Interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
if spec.Volume != nil { spec.Volume.Name = wrapperVolumeName } return kvh.kubelet.newVolumeMounterFromPlugins(&spec, pod, opts) } func (kvh *kubeletVolumeHost) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) { // The name of wrapper volume is set to "wrapped_{wrapped_volume_name}" wrapperVolumeName := "wrapped_" + volName if spec.Volume != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/projected/projected.go
} func (c *projectedVolumeUnmounter) TearDownAt(dir string) error { klog.V(3).Infof("Tearing down volume %v for pod %v at %v", c.volName, c.podUID, dir) wrapped, err := c.plugin.host.NewWrapperUnmounter(c.volName, wrappedVolumeSpec(), c.podUID) if err != nil { return err } if err = wrapped.TearDownAt(dir); err != nil { return err } c.plugin.deleteServiceAccountToken(c.podUID)
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/controller/volume/attachdetach/attach_detach_controller.go
return nil, fmt.Errorf("NewWrapperMounter not supported by Attach/Detach controller's VolumeHost implementation") } func (adc *attachDetachController) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) { return nil, fmt.Errorf("NewWrapperUnmounter not supported by Attach/Detach controller's VolumeHost implementation") } func (adc *attachDetachController) GetMounter(pluginName string) mount.Interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
} plug, err := f.pluginMgr.FindPluginBySpec(&spec) if err != nil { return nil, err } return plug.NewMounter(&spec, pod, opts) } func (f *fakeVolumeHost) NewWrapperUnmounter(volName string, spec Spec, podUID types.UID) (Unmounter, error) { // The name of wrapper volume is set to "wrapped_{wrapped_volume_name}" wrapperVolumeName := "wrapped_" + volName if spec.Volume != nil {
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/plugins.go
NewWrapperMounter(volName string, spec Spec, pod *v1.Pod, opts VolumeOptions) (Mounter, error) // NewWrapperUnmounter finds an appropriate plugin with which to handle // the provided spec. See comments on NewWrapperMounter for more // context. NewWrapperUnmounter(volName string, spec Spec, podUID types.UID) (Unmounter, error) // Get mounter interface. GetMounter(pluginName string) mount.Interface
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/util/util.go
klog.V(3).Infof("Tearing down volume %v for pod %v at %v", volName, podUID, dir) // Wrap EmptyDir, let it do the teardown. wrapped, err := host.NewWrapperUnmounter(volName, volSpec, podUID) if err != nil { return err } return wrapped.TearDownAt(dir) } // MountOptionFromSpec extracts and joins mount options from volume spec with supplied options
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0)