- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 218 for prober (0.3 sec)
-
pilot/cmd/pilot-agent/status/server.go
} if prober.HTTPGet != nil && prober.HTTPGet.Port.Type != apimirror.Int { return fmt.Errorf("invalid prober config for %v, the port must be int type", path) } if prober.TCPSocket != nil && prober.TCPSocket.Port.Type != apimirror.Int { return fmt.Errorf("invalid prober config for %v, the port must be int type", path) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
pkg/probe/exec/exec.go
"k8s.io/kubernetes/pkg/probe" "k8s.io/klog/v2" "k8s.io/utils/exec" ) const ( maxReadLength = 10 * 1 << 10 // 10KB ) // New creates a Prober. func New() Prober { return execProber{} } // Prober is an interface defining the Probe object for container readiness/liveness checks. type Prober interface { Probe(e exec.Cmd) (probe.Result, string, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.2K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
testCases := []struct { name string probes []ready.Prober err error }{ { name: "success probe", probes: []ready.Prober{rp}, err: nil, }, { name: "not ready probe", probes: []ready.Prober{urp}, err: errors.New("not ready"), }, { name: "both probes", probes: []ready.Prober{rp, urp}, err: errors.New("not ready"),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/probe/exec/exec_test.go
err error }{ // Ok {probe.Success, false, true, "OK", "OK", nil}, // Ok {probe.Success, false, true, "OK", "OK", &fakeExitError{true, 0}}, // Ok - truncated output {probe.Success, false, true, elevenKilobyte, tenKilobyte, nil}, // Run returns error {probe.Unknown, true, true, "", "", fmt.Errorf("test error")}, // Unhealthy {probe.Failure, false, true, "Fail", "", &fakeExitError{true, 1}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3.8K 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/testing/volume_host.go
host.hostUtil = hostutil.NewFakeHostUtil(pathToTypeMap) host.exec = &testingexec.FakeExec{DisableScripts: true} host.pluginMgr = &VolumePluginMgr{} if err := host.pluginMgr.InitPlugins(plugins, nil /* prober */, host); err != nil { t.Fatalf("Failed to init plugins while creating fake volume host: %v", err) } host.subpather = &subpath.FakeSubpath{}
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{} fakePathHandler := volumetest.NewBlockVolumePathHandler()
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/kubelet/server/server.go
) // prober metrics are exposed under a different endpoint s.addMetricsBucketMatcher("metrics/probes") p := compbasemetrics.NewKubeRegistry() _ = compbasemetrics.RegisterProcessStartTime(p.Register) p.MustRegister(prober.ProberResults) p.MustRegister(prober.ProberDuration) s.restfulCont.Handle(proberMetricsPath,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
pkg/kubemark/hollow_kubelet.go
"k8s.io/kubernetes/pkg/kubelet/cadvisor" "k8s.io/kubernetes/pkg/kubelet/cm" containertest "k8s.io/kubernetes/pkg/kubelet/container/testing" probetest "k8s.io/kubernetes/pkg/kubelet/prober/testing" kubetypes "k8s.io/kubernetes/pkg/kubelet/types" kubeletutil "k8s.io/kubernetes/pkg/kubelet/util" "k8s.io/kubernetes/pkg/util/oom" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/configmap"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:10:54 UTC 2024 - 7.8K bytes - Viewed (0)