Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for proxyURL (0.17 sec)

  1. internal/config/subnet/config.go

    		// inputs not performing any network calls.
    		return cfg, nil
    	}
    
    	// Make sure to clone the transport before editing the ProxyURL
    	if proxyURL != nil {
    		ctransport := transport.(*http.Transport).Clone()
    		ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL))
    		cfg.transport = ctransport
    	} else {
    		cfg.transport = transport
    	}
    
    	return cfg, nil
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. pkg/test/framework/components/cluster/kube/factory.go

    }
    
    func buildClientWithProxy(kubeconfig string, proxyURL *url.URL) (istioKube.CLIClient, error) {
    	rc, err := istioKube.DefaultRestConfig(kubeconfig, "", func(config *rest.Config) {
    		config.QPS = 200
    		config.Burst = 400
    	})
    	if err != nil {
    		return nil, err
    	}
    	rc.Proxy = http.ProxyURL(proxyURL)
    	return istioKube.NewCLIClient(istioKube.NewClientConfigForRestConfig(rc))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go

    	proxyUrlChan := make(chan string)
    	go runProxy(t, backendUrl, proxyUrlChan, proxyDone, errCh)
    
    	var proxyUrl string
    	select {
    	case err := <-errCh:
    		t.Fatalf("error listening: %v", err)
    	case proxyUrl = <-proxyUrlChan:
    	}
    
    	conn, err := net.Dial("tcp4", proxyUrl)
    	if err != nil {
    		t.Fatalf("client: error connecting to proxy: %v", err)
    	}
    
    	spdyConn, err := NewClientConnection(conn)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 11:58:57 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. pkg/test/echo/server/forwarder/util.go

    			ProxyAddress: cfg.Request.Hbone.GetAddress(),
    			Headers:      cfg.hboneHeaders,
    			TLS:          cfg.hboneTLSConfig,
    		})
    		return out
    	}
    	proxyURL, _ := url.Parse(cfg.Proxy)
    	if len(cfg.Proxy) > 0 && proxyURL.Scheme == "socks5" {
    		dialer, _ := proxy.SOCKS5("tcp", proxyURL.Host, nil, proxy.Direct)
    		return dialer.(hbone.Dialer)
    	}
    	out := &net.Dialer{
    		Timeout: common.ConnectionTimeout,
    	}
    	if cfg.forceDNSLookup {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Oct 08 09:39:20 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  5. src/cmd/go/internal/modfetch/sumdb.go

    			return errUseProxy
    		case "direct", "off":
    			return errProxyOff
    		default:
    			proxyURL, err := url.Parse(proxy)
    			if err != nil {
    				return err
    			}
    			if _, err := web.GetBytes(web.Join(proxyURL, "sumdb/"+c.name+"/supported")); err != nil {
    				return err
    			}
    			// Success! This proxy will help us.
    			c.base = web.Join(proxyURL, "sumdb/"+c.name)
    			return nil
    		}
    	})
    	if errors.Is(err, fs.ErrNotExist) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 20 15:02:47 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  6. pkg/probe/http/http.go

    	// We do not want the probe use node's local proxy set.
    	transport := utilnet.SetTransportDefaults(
    		&http.Transport{
    			TLSClientConfig:    config,
    			DisableKeepAlives:  true,
    			Proxy:              http.ProxyURL(nil),
    			DisableCompression: true, // removes Accept-Encoding header
    			// DialContext creates unencrypted TCP connections
    			// and is also used by the transport for HTTPS connection
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 10 00:37:32 UTC 2023
    - 5K bytes
    - Viewed (0)
  7. pkg/test/echo/server/forwarder/http.go

    		}
    
    		// Set the proxy in the transport, if specified.
    		// for socks5 proxy is setup is done in the newDialer function.
    		if !strings.HasPrefix(cfg.Proxy, "socks5://") {
    			out.Proxy = cfg.proxyURL
    		}
    		return out
    	}
    	noCloseFn := func() {}
    
    	// Always create a new HTTP transport for each request, since HTTP can't multiplex over
    	// a single connection.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top