- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for NewUnmounter (0.21 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/csi/csi_test.go
if err != nil || mounter == nil { t.Fatalf("csiTest.VolumeAll volPlugin.NewMounter is nil or error: %s", err) } unmounter, err := volPlug.NewUnmounter(test.specName, pod.GetUID()) if err != nil { t.Fatal("csiTest.VolumeAll volumePlugin.NewUnmounter failed:", err) } csiUnmounter := unmounter.(*csiMountMgr) csiUnmounter.csiClient = csiClient
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
if spec.Volume != nil { spec.Volume.Name = wrapperVolumeName } plugin, err := kvh.kubelet.volumePluginMgr.FindPluginBySpec(&spec) if err != nil { return nil, err } return plugin.NewUnmounter(spec.Name(), podUID) } func (kvh *kubeletVolumeHost) GetMounter(pluginName string) mount.Interface { return kvh.kubelet.mounter } func (kvh *kubeletVolumeHost) GetHostName() string {
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/downwardapi/downwardapi_test.go
plugin: plugin, pod: pod, mounter: mounter, volumePath: volumePath, rootDir: rootDir, } } func (test *downwardAPITest) tearDown() { unmounter, err := test.plugin.NewUnmounter(test.name, testPodUID) if err != nil { test.t.Errorf("Failed to make a new Unmounter: %v", err) } if unmounter == nil { test.t.Fatalf("Got a nil Unmounter") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 04:48:49 UTC 2023 - 11.2K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo_test.go
} else { allErrs = append(allErrs, fmt.Errorf("SetUp() failed: %v", err)) } } unmounter, err := plug.NewUnmounter("vol1", types.UID("poduid")) if err != nil { allErrs = append(allErrs, fmt.Errorf("failed to make a new Unmounter: %w", err)) return allErrs } if unmounter == nil { allErrs = append(allErrs,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 08:26:26 UTC 2024 - 12K 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/controller/volume/attachdetach/testing/testvolumespec.go
plugin.pluginLock.Lock() defer plugin.pluginLock.Unlock() if spec == nil { plugin.ErrorEncountered = true } return nil, nil } func (plugin *TestPlugin) NewUnmounter(name string, podUID types.UID) (volume.Unmounter, error) { return nil, nil } func (plugin *TestPlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K 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)