- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 775 for prober3 (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go
return newETCD3ProberMonitor(c) default: return nil, fmt.Errorf("unknown storage type: %s", c.Type) } } // Prober is an interface that defines the Probe function for doing etcd readiness/liveness checks. type Prober interface { Probe(ctx context.Context) error Close() error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
var kmsHealthChecks []healthz.HealthChecker transformers, probes, kmsUsed, err := getTransformerOverridesAndKMSPluginProbes(ctx, config, apiServerID) if err != nil { return nil, nil, nil, err } for i := range probes { probe := probes[i] kmsHealthChecks = append(kmsHealthChecks, probe.toHealthzCheck(i)) } return transformers, kmsHealthChecks, kmsUsed, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
releasenotes/notes/48047-probe-return-body.yaml
apiVersion: release-notes/v2 kind: feature area: traffic-management releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 30 10:47:14 UTC 2023 - 234 bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/merge-probers.yaml
dwq <******@****.***> 1673232888 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 09 02:54:48 UTC 2023 - 7.4K bytes - Viewed (0) -
releasenotes/notes/startupProbe.yaml
Startup probes run only at the start of the pod. Once the startup probe completes, readiness probes will continue. By using a startup probe, we can poll for the sidecar to start more aggressively, without polling as aggressively throughout the entire pod's lifecycle. On average, this improves pod startup time by roughly 1s.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Oct 13 23:27:34 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/volume/flexvolume/probe_test.go
assert.NoError(t, err) // Should no longer probe. // Act events, err = prober.Probe() // Assert assert.Equal(t, 0, len(events)) assert.NoError(t, err) } // Probes newly added drivers after prober is running. func TestProberAddRemoveDriver(t *testing.T) { // Arrange _, fs, watcher, prober := initTestEnvironment(t) prober.Probe() events, err := prober.Probe() assert.NoError(t, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/kubelet/prober/worker_test.go
} // Exceeding FailureThreshold should cause resultRun to // reset to 0 so that the probe on the restarted pod // also gets FailureThreshold attempts to succeed. m.prober.exec = fakeExecProber{probe.Failure, nil} msg = "3rd probe failure, result failure" expectContinue(t, w, w.doProbe(ctx), msg) expectResult(t, w, results.Failure, msg) if w.resultRun != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 23:48:10 UTC 2023 - 16.1K bytes - Viewed (0) -
src/net/ipsock_posix.go
// and we don't need to probe the capability. probes = probes[:1] } for i := range probes { s, err := sysSocket(syscall.AF_INET6, syscall.SOCK_STREAM, syscall.IPPROTO_TCP) if err != nil { continue } defer poll.CloseFunc(s) syscall.SetsockoptInt(s, syscall.IPPROTO_IPV6, syscall.IPV6_V6ONLY, probes[i].value) sa, err := probes[i].laddr.sockaddr(syscall.AF_INET6) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.6K bytes - Viewed (0) -
pkg/probe/http/http_test.go
redirect string expectLocalResult probe.Result expectNonLocalResult probe.Result }{ "local success": {"/success", probe.Success, probe.Success}, "local fail": {"/fail", probe.Failure, probe.Failure}, "newport success": {newportServer.URL + "/success", probe.Success, probe.Success}, "newport fail": {newportServer.URL + "/fail", probe.Failure, probe.Failure},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 18 01:40:08 UTC 2023 - 15.7K bytes - Viewed (0) -
pkg/probe/http/request.go
"strconv" "strings" v1 "k8s.io/api/core/v1" "k8s.io/component-base/version" "k8s.io/kubernetes/pkg/probe" ) // NewProbeRequest returns an http.Request suitable for use as a request for a // probe. func NewProbeRequest(url *url.URL, headers http.Header) (*http.Request, error) { return newProbeRequest(url, headers, "probe") } // NewRequestForHTTPGetAction returns an http.Request derived from httpGet.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 07:39:55 UTC 2023 - 3.3K bytes - Viewed (0)