- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewHTTPProber (0.13 sec)
-
pkg/istio-agent/health/health_probers_test.go
}, } for _, tt := range tests { t.Run(tt.desc, func(t *testing.T) { server, port := createHTTPServer(tt.statusCode) defer server.Close() httpProber := NewHTTPProber( &v1alpha3.HTTPHealthCheckConfig{ Path: "/test/health/check", Port: port, Host: "127.0.0.1", Scheme: "http", }, false) if tt.statusCode == -1 { server.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 14 19:26:09 UTC 2021 - 4.8K bytes - Viewed (0) -
pkg/istio-agent/health/health_check.go
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) case *v1alpha3.ReadinessProbe_TcpSocket: prober = &TCPProber{Config: healthCheckMethod.TcpSocket} case *v1alpha3.ReadinessProbe_Exec: prober = &ExecProber{Config: healthCheckMethod.Exec}
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/istio-agent/health/health_probers.go
func (p *ProbeResult) IsHealthy() bool { return *p == Healthy } type HTTPProber struct { Config *v1alpha3.HTTPHealthCheckConfig Transport *http.Transport } var _ Prober = &HTTPProber{} func NewHTTPProber(cfg *v1alpha3.HTTPHealthCheckConfig, ipv6 bool) *HTTPProber { h := new(HTTPProber) h.Config = cfg // Create an http.Transport with TLSClientConfig for HTTPProber if the scheme is https,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.7K bytes - Viewed (0)