- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewFakeKubeletVolumeHost (0.27 sec)
-
pkg/volume/hostpath/host_path_test.go
} return typeList } func TestCanSupport(t *testing.T) { plugMgr := volume.VolumePluginMgr{} plugMgr.InitPlugins(ProbeVolumePlugins(volume.VolumeConfig{}), nil /* prober */, volumetest.NewFakeKubeletVolumeHost(t, "fake", nil, nil)) plug, err := plugMgr.FindPluginByName(hostPathPluginName) if err != nil { t.Fatal("Can't find the plugin by name") } if plug.GetPluginName() != hostPathPluginName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/volume/local/local_test.go
if err != nil { t.Fatalf("can't make a temp dir: %v", err) } plugMgr := volume.VolumePluginMgr{} plugMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, volumetest.NewFakeKubeletVolumeHost(t, tmpDir, nil, nil)) plug, err := plugMgr.FindPluginByName(localVolumePluginName) if err != nil { os.RemoveAll(tmpDir) t.Fatalf("Can't find the plugin by name") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 10:53:39 UTC 2023 - 22.5K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
fakeVolumeHost } var _ KubeletVolumeHost = &fakeKubeletVolumeHost{} var _ FakeVolumeHost = &fakeKubeletVolumeHost{} func NewFakeKubeletVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) *fakeKubeletVolumeHost { return newFakeKubeletVolumeHost(t, rootDir, kubeClient, plugins, nil, "", nil, 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/kubelet/volumemanager/volume_manager_test.go
}, } fakeRecorder := &record.FakeRecorder{} plugMgr := &volume.VolumePluginMgr{} // TODO (#51147) inject mock prober fakeVolumeHost := volumetest.NewFakeKubeletVolumeHost(t, tmpDir, kubeClient, nil) fakeVolumeHost.WithNode(node) plugMgr.InitPlugins([]volume.VolumePlugin{attachablePlug, unattachablePlug}, nil /* prober */, fakeVolumeHost) stateProvider := &fakePodStateProvider{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/volume/testing/testing.go
} func GetTestKubeletVolumePluginMgr(t *testing.T) (*volume.VolumePluginMgr, *FakeVolumePlugin) { plugins := ProbeVolumePlugins(volume.VolumeConfig{}) v := NewFakeKubeletVolumeHost( t, "", /* rootDir */ nil, /* kubeClient */ plugins, /* plugins */ ) return v.GetPluginMgr(), plugins[0].(*FakeVolumePlugin) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/volume/projected/projected_test.go
tempDir, err := os.MkdirTemp("", "projected_volume_test.") if err != nil { t.Fatalf("can't make a temp rootdir: %v", err) } return tempDir, volumetest.NewFakeKubeletVolumeHost(t, tempDir, clientset, emptydir.ProbeVolumePlugins()) } func TestCanSupport(t *testing.T) { pluginMgr := volume.VolumePluginMgr{} tempDir, host := newTestHost(t, nil) defer os.RemoveAll(tempDir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 40.5K bytes - Viewed (0)