Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewWrapperUnmounter (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top