Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DialerFor (0.12 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/proxy/dial.go

    // TLSConfig of the http.Transport
    func DialURL(ctx context.Context, url *url.URL, transport http.RoundTripper) (net.Conn, error) {
    	dialAddr := netutil.CanonicalAddr(url)
    
    	dialer, err := utilnet.DialerFor(transport)
    	if err != nil {
    		klog.V(5).Infof("Unable to unwrap transport %T to get dialer: %v", transport, err)
    	}
    
    	switch url.Scheme {
    	case "http":
    		if dialer != nil {
    			return dialer(ctx, "tcp", dialAddr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/proxy/dial_test.go

    			tlsConfigCopy.Clone()
    			transport := &http.Transport{
    				DialContext:     tc.Dial,
    				TLSClientConfig: tlsConfigCopy,
    			}
    
    			extractedDial, err := utilnet.DialerFor(transport)
    			if err != nil {
    				t.Fatal(err)
    			}
    			if fmt.Sprintf("%p", extractedDial) != fmt.Sprintf("%p", tc.Dial) {
    				t.Fatalf("%s: Unexpected dial", k)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/net/http.go

    }
    
    type RoundTripperWrapper interface {
    	http.RoundTripper
    	WrappedRoundTripper() http.RoundTripper
    }
    
    type DialFunc func(ctx context.Context, net, addr string) (net.Conn, error)
    
    func DialerFor(transport http.RoundTripper) (DialFunc, error) {
    	if transport == nil {
    		return nil, nil
    	}
    
    	switch transport := transport.(type) {
    	case *http.Transport:
    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. CHANGELOG/CHANGELOG-1.12.md

    - api-machinery utility functions `SetTransportDefaults` and `DialerFor` once again respect custom Dial functions set on transports ([#65547](https://github.com/kubernetes/kubernetes/pull/65547), [@liggitt](https://github.com/liggitt))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 293.8K bytes
    - Viewed (0)
Back to top