Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 24 of 24 for NewUnmounter (0.18 sec)

  1. pkg/volume/local/local.go

    		},
    		mountOptions: util.MountOptionFromSpec(spec),
    		readOnly:     readOnly,
    	}, nil
    
    }
    
    func (plugin *localVolumePlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) {
    	return &localVolumeUnmounter{
    		localVolume: &localVolume{
    			podUID:  podUID,
    			volName: volName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_plugin.go

    	dir := mounter.GetPath()
    	mounter.MetricsProvider = NewMetricsCsi(volumeHandle, dir, csiDriverName(driverName))
    	klog.V(4).Info(log("mounter created successfully"))
    	return mounter, nil
    }
    
    func (p *csiPlugin) NewUnmounter(specName string, podUID types.UID) (volume.Unmounter, error) {
    	klog.V(4).Infof(log("setting up unmounter for [name=%v, podUID=%v]", specName, podUID))
    
    	kvh, ok := p.host.(volume.KubeletVolumeHost)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_plugin_test.go

    			volDataKey.driverName: testDriver,
    			volDataKey.volHandle:  testVol,
    		},
    	); err != nil {
    		t.Fatalf("failed to save volume data: %v", err)
    	}
    
    	// test unmounter
    	unmounter, err := plug.NewUnmounter(pv.ObjectMeta.Name, testPodUID)
    	csiUnmounter := unmounter.(*csiMountMgr)
    
    	if err != nil {
    		t.Fatalf("Failed to make a new Unmounter: %v", err)
    	}
    
    	if csiUnmounter == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_generator.go

    	}
    	volumeUnmounter, newUnmounterErr := volumePlugin.NewUnmounter(
    		volumeToUnmount.InnerVolumeSpecName, volumeToUnmount.PodUID)
    	if newUnmounterErr != nil {
    		return volumetypes.GeneratedOperations{}, volumeToUnmount.GenerateErrorDetailed("UnmountVolume.NewUnmounter failed", newUnmounterErr)
    	}
    
    	unmountVolumeFunc := func() volumetypes.OperationContext {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
Back to top