- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 219 for Probes (2.07 sec)
-
pilot/cmd/pilot-agent/status/server.go
upstreamLocalAddress = UpstreamLocalAddressIPv6 } } probes := make([]ready.Prober, 0) if !config.NoEnvoy { probes = append(probes, &ready.Probe{ LocalHostAddr: localhost, AdminPort: config.AdminPort, Context: config.Context, NoEnvoy: config.NoEnvoy, }) } if config.GRPCBootstrap != "" { probes = append(probes, grpcready.NewProbe(config.GRPCBootstrap)) }
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/kubelet/prober/prober_manager.go
// readinessManager manages the results of readiness probes readinessManager results.Manager // livenessManager manages the results of liveness probes livenessManager results.Manager // startupManager manages the results of startup probes startupManager results.Manager // prober executes the probe actions. prober *prober start time.Time }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/kubelet/prober/worker.go
return true } } else { // Disable other probes until container has started. if w.probeType != startup { return true } } // Note, exec probe does NOT have access to pod environment variables or downward API result, err := w.probeManager.prober.probe(ctx, w.probeType, w.pod, status, w.container, w.containerID) if err != nil { // Prober error, throw away the result. return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K 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/kube/inject/inject_test.go
in: "hello-probes.yaml", want: "hello-probes.proxyHoldsApplication.yaml.injected", setFlags: []string{ `values.global.proxy.holdApplicationUntilProxyStarts=true`, }, }, { // Verifies that HoldApplicationUntilProxyStarts in proxyconfig sets lifecycle hook in: "hello-probes-proxyHoldApplication-ProxyConfig.yaml", want: "hello-probes-proxyHoldApplication-ProxyConfig.yaml.injected",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 34.1K 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) -
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) -
src/net/dial.go
// If negative, keep-alive probes are disabled. KeepAlive time.Duration // KeepAliveConfig specifies the keep-alive probe configuration // for an active network connection, when supported by the // protocol and operating system. // // If KeepAliveConfig.Enable is true, keep-alive probes are enabled. // If KeepAliveConfig.Enable is false and KeepAlive is negative, // keep-alive probes are disabled.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
src/net/tcpsock.go
type KeepAliveConfig struct { // If Enable is true, keep-alive probes are enabled. Enable bool // Idle is the time that the connection must be idle before // the first keep-alive probe is sent. // If zero, a default value of 15 seconds is used. Idle time.Duration // Interval is the time between keep-alive probes. // If zero, a default value of 15 seconds is used. Interval time.Duration
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0)