- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 157 for Wrobel (0.1 sec)
-
pkg/kubelet/prober/prober.go
httpprobe "k8s.io/kubernetes/pkg/probe/http" tcpprobe "k8s.io/kubernetes/pkg/probe/tcp" "k8s.io/utils/exec" "k8s.io/klog/v2" ) const maxProbeRetries = 3 // Prober helps to check the liveness/readiness/startup of a container. type prober struct { exec execprobe.Prober http httpprobe.Prober tcp tcpprobe.Prober grpc grpcprobe.Prober runner kubecontainer.CommandRunner
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:50:13 UTC 2024 - 8.7K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/grpcready/probe.go
) var _ ready.Prober = &probe{} type probe struct { sync.RWMutex bootstrapPath string bootstrap *grpcxds.Bootstrap } // NewProbe returns a probe that checks if a valid bootstrap file can be loaded once. // If that bootstrap file has a file_watcher cert provider, we also ensure those certs exist. func NewProbe(bootstrapPath string) ready.Prober { return &probe{bootstrapPath: bootstrapPath} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 28 16:58:31 UTC 2021 - 1.9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/ready/probe.go
Check() error } var _ Prober = &Probe{} // Check executes the probe and returns an error if the probe fails. func (p *Probe) Check() error { // First, check that Envoy has received a configuration update from Pilot. if err := p.checkConfigStatus(); err != nil { return err } return p.isEnvoyReady() } // checkConfigStatus checks to make sure initial configs have been received from Pilot.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 00:35:05 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/volume/flexvolume/probe.go
if err := prober.createPluginDir(); err != nil { return err } if err := prober.initWatcher(); err != nil { return err } return nil } // If probeAllNeeded is true, probe all pluginDir // else probe events in eventsMap func (prober *flexVolumeProber) Probe() (events []volume.ProbeEvent, err error) { if prober.probeAllNeeded { prober.testAndSetProbeAllNeeded(false) return prober.probeAll() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 9K bytes - Viewed (0) -
releasenotes/notes/agent-probe-keepalives.yaml
releaseNotes: - | **Improved** istio-agent health probe rewrite to not re-use connections, mirring Kubernetes' probing behavior. upgradeNotes: - title: Health Probes will no longer re-use connections content: | Health probes using the istio-agent [health probe rewrite](https://istio.io/latest/docs/ops/configuration/mesh/app-health-check/) will
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 07 20:06:21 UTC 2021 - 963 bytes - Viewed (0) -
pkg/istio-agent/health/health_check.go
func NewWorkloadHealthChecker(cfg *v1alpha3.ReadinessProbe, envoyProbe ready.Prober, proxyAddrs []string, ipv6 bool) *WorkloadHealthChecker { // if a config does not exist return a no-op prober if cfg == nil { return nil } cfg = fillInDefaults(cfg, proxyAddrs) var prober Prober switch healthCheckMethod := cfg.HealthCheckMethod.(type) { case *v1alpha3.ReadinessProbe_HttpGet: prober = NewHTTPProber(healthCheckMethod.HttpGet, ipv6)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 21 03:06:44 UTC 2021 - 5.7K bytes - Viewed (0) -
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/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)