- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 924 for prober (0.07 sec)
-
pilot/cmd/pilot-agent/options/statusserver.go
PodIP: InstanceIPVar.Get(), AdminPort: uint16(proxyConfig.ProxyAdminPort), StatusPort: uint16(proxyConfig.StatusPort), KubeAppProbers: kubeAppProberNameVar.Get(), NodeType: t, Probes: []ready.Prober{agent}, NoEnvoy: agent.EnvoyDisabled(), FetchDNS: agent.GetDNSTable, GRPCBootstrap: agent.GRPCBootstrapPath(), TriggerDrain: func() { agent.DrainNow() }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 23:51:52 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/volume/plugins.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/plugins_test.go
func newTestPlugin() []VolumePlugin { return []VolumePlugin{&testPlugins{}} } func TestVolumePluginMgrFunc(t *testing.T) { vpm := VolumePluginMgr{} var prober DynamicPluginProber = nil // TODO (#51147) inject mock vpm.InitPlugins(newTestPlugin(), prober, nil) plug, err := vpm.FindPluginByName(testPluginName) if err != nil { t.Fatal("Can't find the plugin by name") } if plug.GetPluginName() != testPluginName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 4.3K bytes - Viewed (0) -
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) -
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) -
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) -
pkg/volume/portworx/portworx_test.go
if err != nil { t.Fatalf("can't make a 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/portworx-volume") if err != nil { t.Fatal("Can't find the plugin by name") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 21 02:17:04 UTC 2021 - 7.4K bytes - Viewed (0) -
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) -
pkg/registry/core/componentstatus/validator_test.go
}{ {probe.Unknown, "", fmt.Errorf("probe error"), probe.Unknown, "", true, nil}, {probe.Failure, "", nil, probe.Failure, "", false, nil}, {probe.Success, "foo", nil, probe.Failure, "foo", true, matchError}, {probe.Success, "foo", nil, probe.Success, "foo", false, nil}, } s := HttpServer{Addr: "foo.com", Port: 8080, Path: "/healthz"} for _, test := range tests { fakeProber := &fakeHttpProber{ result: test.probeResult,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 13 08:10:29 UTC 2023 - 1.9K bytes - Viewed (0) -
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)