- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 384 for Wrobel (0.08 sec)
-
pkg/probe/tcp/tcp.go
import ( "net" "strconv" "time" "k8s.io/kubernetes/pkg/probe" "k8s.io/klog/v2" ) // New creates Prober. func New() Prober { return tcpProber{} } // Prober is an interface that defines the Probe function for doing TCP readiness/liveness checks. type Prober interface { Probe(host string, port int, timeout time.Duration) (probe.Result, string, error) } type tcpProber struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 16:57:41 UTC 2023 - 1.9K 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/istio-agent/health/health_probers.go
} type EnvoyProber struct { Config ready.Prober } var _ Prober = &EnvoyProber{} func (a EnvoyProber) Probe(time.Duration) (ProbeResult, error) { if err := a.Config.Check(); err != nil { return Unhealthy, err } return Healthy, nil } type AggregateProber struct { Probes []Prober } var _ Prober = &AggregateProber{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/probe/http/http.go
return httpProber{transport, followNonLocalRedirects} } // Prober is an interface that defines the Probe function for doing HTTP readiness/liveness checks. type Prober interface { Probe(req *http.Request, timeout time.Duration) (probe.Result, string, error) } type httpProber struct { transport *http.Transport followNonLocalRedirects bool } // Probe returns a ProbeRunner capable of running an HTTP check.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 10 00:37:32 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/prober/common_test.go
).(*manager) // Don't actually execute probes. m.prober.exec = fakeExecProber{probe.Success, nil} return m } func newTestWorker(m *manager, probeType probeType, probeSpec v1.Probe) *worker { pod := getTestPod() setTestProbe(pod, probeType, probeSpec) return newWorker(m, probeType, pod, pod.Spec.Containers[0]) } type fakeExecProber struct { result probe.Result err error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 16:57:26 UTC 2023 - 4.3K 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/kubelet/prober/scale_test.go
// causing conntrack entries and ephemeral ports to be hold for 60 seconds // despite the probe may have finished in less than 1 second. // If the rate of probes is higher than the rate the OS recycles the ports used, // it can consume a considerable number of ephemeral ports or conntrack entries. // These tests verify that after certain period the probes keep working, if the probes // don't close the sockets faster, they will start to fail.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K 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) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/probe.go
TerminationGracePeriodSeconds *int64 `json:"terminationGracePeriodSeconds,omitempty"` } // ProbeApplyConfiguration constructs an declarative configuration of the Probe type for use with // apply. func Probe() *ProbeApplyConfiguration { return &ProbeApplyConfiguration{} } // WithExec sets the Exec field in the declarative configuration to the given value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 17:31:23 UTC 2021 - 5.7K bytes - Viewed (0) -
releasenotes/notes/http2-probes.yaml
issues: - 40173 releaseNotes: - | **Added** support for ALPN negotiation to Istio [health checks](https://istio.io/latest/docs/ops/configuration/mesh/app-health-check/), mirroring
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 08 19:15:41 UTC 2022 - 440 bytes - Viewed (0)