Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 415 for prober (0.16 sec)

  1. pkg/volume/fc/fc_test.go

    	if err != nil {
    		t.Fatalf("error creating temp dir: %v", err)
    	}
    	defer os.RemoveAll(tmpDir)
    
    	plugMgr := volume.VolumePluginMgr{}
    	plugMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, volumetest.NewFakeVolumeHost(t, tmpDir, nil, nil))
    
    	plug, err := plugMgr.FindPluginByName("kubernetes.io/fc")
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 14.1K bytes
    - Viewed (0)
  2. pkg/volume/configmap/configmap_test.go

    }
    
    func TestCanSupport(t *testing.T) {
    	pluginMgr := volume.VolumePluginMgr{}
    	tempDir, host := newTestHost(t, nil)
    	defer os.RemoveAll(tempDir)
    	pluginMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host)
    
    	plugin, err := pluginMgr.FindPluginByName(configMapPluginName)
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    	if plugin.GetPluginName() != configMapPluginName {
    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/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")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  4. pkg/volume/local/local_test.go

    	tmpDir, err := utiltesting.MkTmpdir("localVolumeTest")
    	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)
  5. pkg/volume/iscsi/iscsi_test.go

    	if err != nil {
    		t.Fatalf("error creating temp dir: %v", err)
    	}
    	defer os.RemoveAll(tmpDir)
    
    	plugMgr := volume.VolumePluginMgr{}
    	plugMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, volumetest.NewFakeVolumeHost(t, tmpDir, nil, nil))
    
    	plug, err := plugMgr.FindPluginByName("kubernetes.io/iscsi")
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 16.4K bytes
    - Viewed (0)
  6. pkg/volume/secret/secret_test.go

    }
    
    func TestCanSupport(t *testing.T) {
    	pluginMgr := volume.VolumePluginMgr{}
    	tempDir, host := newTestHost(t, nil)
    	defer os.RemoveAll(tempDir)
    	pluginMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host)
    
    	plugin, err := pluginMgr.FindPluginByName(secretPluginName)
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    	if plugin.GetPluginName() != secretPluginName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 19.5K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go

    					Plugin: volumetesting.FakeVolumePlugin{
    						PluginName: "attachable",
    					},
    				},
    			},
    		},
    	}
    	volumePluginMgr := volume.VolumePluginMgr{}
    	volumePluginMgr.InitPlugins(plugins, nil /* prober */, fakeVolumeHost)
    	seLinuxTranslator := util.NewFakeSELinuxLabelTranslator()
    	dsw := NewDesiredStateOfWorld(&volumePluginMgr, seLinuxTranslator)
    
    	testcases := map[string]struct {
    		pod1 *v1.Pod
    		pod2 *v1.Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 34K bytes
    - Viewed (0)
  8. pkg/volume/downwardapi/downwardapi_test.go

    }
    
    func TestCanSupport(t *testing.T) {
    	pluginMgr := volume.VolumePluginMgr{}
    	tmpDir, host := newTestHost(t, nil)
    	defer os.RemoveAll(tmpDir)
    	pluginMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host)
    
    	plugin, err := pluginMgr.FindPluginByName(downwardAPIPluginName)
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    	if plugin.GetPluginName() != downwardAPIPluginName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 04:48:49 UTC 2023
    - 11.2K bytes
    - Viewed (0)
  9. pkg/volume/git_repo/git_repo_test.go

    }
    
    func TestCanSupport(t *testing.T) {
    	plugMgr := volume.VolumePluginMgr{}
    	tempDir, host := newTestHost(t)
    	defer os.RemoveAll(tempDir)
    	plugMgr.InitPlugins(ProbeVolumePlugins(), nil /* prober */, host)
    
    	plug, err := plugMgr.FindPluginByName("kubernetes.io/git-repo")
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    	if plug.GetPluginName() != "kubernetes.io/git-repo" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 08:26:26 UTC 2024
    - 12K bytes
    - Viewed (0)
  10. pkg/kubelet/volume_host.go

    	kubelet *Kubelet,
    	secretManager secret.Manager,
    	configMapManager configmap.Manager,
    	tokenManager *token.Manager,
    	clusterTrustBundleManager clustertrustbundle.Manager,
    	plugins []volume.VolumePlugin,
    	prober volume.DynamicPluginProber) (*volume.VolumePluginMgr, error) {
    
    	// Initialize csiDriverLister before calling InitPlugins
    	var informerFactory informers.SharedInformerFactory
    	var csiDriverLister storagelisters.CSIDriverLister
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top