- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newProbeRequest (0.27 sec)
-
pkg/probe/http/request.go
"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) -
pkg/probe/http/http_test.go
// take some time to wait server boot time.Sleep(2 * time.Second) url, err := url.Parse("http://example.com") if err != nil { t.Errorf("proxy test unexpected error: %v", err) } req, err := NewProbeRequest(url, http.Header{}) if err != nil { t.Fatal(err) } _, response, _ := prober.Probe(req, time.Second*3) if response == res { t.Errorf("proxy test unexpected error: the probe is using proxy") }
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/registry/core/componentstatus/validator.go
}) scheme := "http" if server.EnableHTTPS { scheme = "https" } url := utilnet.FormatURL(scheme, server.Addr, server.Port, server.Path) req, err := httpprober.NewProbeRequest(url, nil) if err != nil { return probe.Unknown, "", fmt.Errorf("failed to construct probe request: %w", err) } result, data, err := server.Prober.Probe(req, probeTimeOut) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 20 13:08:41 UTC 2023 - 2.9K bytes - Viewed (0)