Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for NewUnmounter (0.18 sec)

  1. 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)
  2. pkg/volume/configmap/configmap_test.go

    			}
    		}
    	}
    }
    
    func doTestCleanAndTeardown(plugin volume.VolumePlugin, podUID types.UID, testVolumeName, volumePath string, t *testing.T) {
    	unmounter, err := plugin.NewUnmounter(testVolumeName, podUID)
    	if err != nil {
    		t.Errorf("Failed to make a new Unmounter: %v", err)
    	}
    	if unmounter == nil {
    		t.Fatalf("Got a nil Unmounter")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 11:12:06 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  3. pkg/volume/secret/secret_test.go

    			}
    		}
    	}
    }
    
    func doTestCleanAndTeardown(plugin volume.VolumePlugin, podUID types.UID, testVolumeName, volumePath string, t *testing.T) {
    	unmounter, err := plugin.NewUnmounter(testVolumeName, podUID)
    	if err != nil {
    		t.Errorf("Failed to make a new Unmounter: %v", err)
    	}
    	if unmounter == nil {
    		t.Fatalf("Got a nil Unmounter")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 19.5K bytes
    - Viewed (0)
  4. pkg/volume/hostpath/host_path_test.go

    	if path != volPath {
    		t.Errorf("Got unexpected path: %s", path)
    	}
    
    	if err := mounter.SetUp(volume.MounterArgs{}); err != nil {
    		t.Errorf("Expected success, got: %v", err)
    	}
    
    	unmounter, err := plug.NewUnmounter("vol1", types.UID("poduid"))
    	if err != nil {
    		t.Errorf("Failed to make a new Unmounter: %v", err)
    	}
    	if unmounter == nil {
    		t.Fatalf("Got a nil Unmounter")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  5. pkg/volume/local/local_test.go

    			if os.IsNotExist(err) {
    				t.Errorf("SetUp() failed, volume path not created: %s", path)
    			} else {
    				t.Errorf("SetUp() failed: %v", err)
    			}
    		}
    	}
    
    	unmounter, err := plug.NewUnmounter(testPVName, pod.UID)
    	if err != nil {
    		t.Errorf("Failed to make a new Unmounter: %v", err)
    	}
    	if unmounter == nil {
    		t.Fatalf("Got a nil Unmounter")
    	}
    
    	if err := unmounter.TearDown(); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  6. 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)
  7. pkg/volume/csi/csi_mounter_test.go

    			volDataKey.driverName: testDriver,
    			volDataKey.volHandle:  testVol,
    		},
    	); err != nil {
    		t.Fatalf("failed to save volume data: %v", err)
    	}
    
    	unmounter, err := plug.NewUnmounter(pv.ObjectMeta.Name, testPodUID)
    	if err != nil {
    		t.Fatalf("failed to make a new Unmounter: %v", err)
    	}
    
    	csiUnmounter := unmounter.(*csiMountMgr)
    	csiUnmounter.csiClient = setupClient(t, true)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 50.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. pkg/controller/volume/persistentvolume/framework_test.go

    	return nil, fmt.Errorf("Mounter is not supported by this plugin")
    }
    
    func (plugin *mockVolumePlugin) NewUnmounter(name string, podUID types.UID) (volume.Unmounter, error) {
    	return nil, fmt.Errorf("Unmounter is not supported by this plugin")
    }
    
    // Provisioner interfaces
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 09:54:00 UTC 2023
    - 38.3K bytes
    - Viewed (0)
Back to top