Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ProxyFromEnvironment (0.57 sec)

  1. cmd/kubeadm/app/preflight/checks_test.go

    		t.Fatalf("unexpected err: %v", err)
    	}
    	proxy, err := http.ProxyFromEnvironment(req)
    	if err != nil {
    		t.Fatalf("unexpected err: %v", err)
    	}
    	if proxy == nil {
    		t.Skip("test skipped as ProxyFromEnvironment already initialized in environment without defined HTTP proxy")
    	}
    	t.Log("http.ProxyFromEnvironment is usable, continue executing test")
    }
    
    func TestKubeletVersionCheck(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    	conn net.Conn
    
    	// Dialer is the dialer used to connect.  Used if non-nil.
    	Dialer *net.Dialer
    
    	// proxier knows which proxy to use given a request, defaults to http.ProxyFromEnvironment
    	// Used primarily for mocking the proxy discovery in tests.
    	proxier func(req *http.Request) (*url.URL, error)
    
    	// pingPeriod is a period for sending Ping frames over established
    	// connections.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/net/http.go

    	if t.Proxy == nil || isDefault(t.Proxy) {
    		// http.ProxyFromEnvironment doesn't respect CIDRs and that makes it impossible to exclude things like pod and service IPs from proxy settings
    		// ProxierWithNoProxyCIDR allows CIDR rules in NO_PROXY
    		t.Proxy = NewProxierWithNoProxyCIDR(http.ProxyFromEnvironment)
    	}
    	// If no custom dialer is set, use the default context dialer
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 05 00:08:58 UTC 2022
    - 20.8K bytes
    - Viewed (0)
  4. pilot/pkg/model/jwks_resolver.go

    		refreshIntervalOnFailure: refreshIntervalOnFailure,
    		retryInterval:            retryInterval,
    		httpClient: &http.Client{
    			Transport: &http.Transport{
    				Proxy:             http.ProxyFromEnvironment,
    				DisableKeepAlives: true,
    			},
    		},
    	}
    
    	caCertPool, err := x509.SystemCertPool()
    	caCertsFound := true
    	if err != nil {
    		caCertsFound = false
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 09:47:21 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  5. src/vendor/golang.org/x/net/http/httpproxy/proxy.go

    // license that can be found in the LICENSE file.
    
    // Package httpproxy provides support for HTTP proxy determination
    // based on environment variables, as provided by net/http's
    // ProxyFromEnvironment function.
    //
    // The API is not subject to the Go 1 compatibility promise and may change at
    // any time.
    package httpproxy
    
    import (
    	"errors"
    	"fmt"
    	"net"
    	"net/url"
    	"os"
    	"strings"
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Mar 09 00:09:40 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. pkg/spiffe/spiffe.go

    		}
    
    		config := &tls.Config{
    			ServerName: u.Hostname(),
    			RootCAs:    caCertPool,
    			MinVersion: tls.VersionTLS12,
    		}
    
    		httpClient.Transport = &http.Transport{
    			Proxy:           http.ProxyFromEnvironment,
    			TLSClientConfig: config,
    			DialContext: (&net.Dialer{
    				Timeout: time.Second * 10,
    			}).DialContext,
    			IdleConnTimeout:       90 * time.Second,
    			TLSHandshakeTimeout:   10 * time.Second,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. cmd/update.go

    	return sha256Sum, releaseTime, releaseInfo, err
    }
    
    func getUpdateTransport(timeout time.Duration) http.RoundTripper {
    	var updateTransport http.RoundTripper = &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		DialContext:           xhttp.NewInternodeDialContext(timeout, globalTCPOptions),
    		IdleConnTimeout:       timeout,
    		TLSHandshakeTimeout:   timeout,
    		ExpectContinueTimeout: timeout,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/x509metrics/server_cert_deprecations_test.go

    			// never performed.
    			caPool := x509.NewCertPool()
    			require.True(t, caPool.AppendCertsFromPEM(caCert))
    
    			client := &http.Client{
    				Transport: &http.Transport{
    					Proxy: http.ProxyFromEnvironment,
    					TLSClientConfig: &tls.Config{
    						RootCAs: caPool,
    					},
    				},
    			}
    
    			_, err = client.Transport.RoundTrip(req)
    
    			if sha1checker.CheckRoundTripError(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 25.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware_test.go

    		responder   *fakeResponder
    		expectedErr = errors.New("EXPECTED")
    	)
    	proxy := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		transport := &http.Transport{
    			Proxy: http.ProxyFromEnvironment,
    			DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
    				return &fakeConn{err: expectedErr}, nil
    			},
    			MaxIdleConns:          100,
    			IdleConnTimeout:       90 * time.Second,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 10 07:29:34 UTC 2023
    - 39.4K bytes
    - Viewed (0)
Back to top