Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newProbeRequest (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top