Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewFakeKubeletVolumeHost (0.27 sec)

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