Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 86 for Dialer (0.12 sec)

  1. src/crypto/tls/tls.go

    	return DialWithDialer(new(net.Dialer), network, addr, config)
    }
    
    // Dialer dials TLS connections given a configuration and a Dialer for the
    // underlying connection.
    type Dialer struct {
    	// NetDialer is the optional dialer to use for the TLS connections'
    	// underlying TCP connections.
    	// A nil NetDialer is equivalent to the net.Dialer zero value.
    	NetDialer *net.Dialer
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    	dialAddr := netutil.CanonicalAddr(url)
    	dialer := s.Dialer
    	if dialer == nil {
    		dialer = &net.Dialer{}
    	}
    
    	if url.Scheme == "http" {
    		return dialer.DialContext(ctx, "tcp", dialAddr)
    	}
    
    	tlsDialer := tls.Dialer{
    		NetDialer: dialer,
    		Config:    s.tlsConfig,
    	}
    	return tlsDialer.DialContext(ctx, "tcp", dialAddr)
    }
    
    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. src/net/dial_test.go

    	defer ln.Close()
    	_, port, err := SplitHostPort(ln.Addr().String())
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	ctx := contextWithNonZeroDeadline{Context: context.Background()}
    	var dialer Dialer
    	c, err := dialer.DialContext(ctx, "tcp", JoinHostPort("", port))
    	if err != nil {
    		t.Fatal(err)
    	}
    	c.Close()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
  4. src/net/dial.go

    	} else {
    		*m = mptcpDisabled
    	}
    }
    
    // A Dialer contains options for connecting to an address.
    //
    // The zero value for each field is equivalent to dialing
    // without that option. Dialing with the zero value of Dialer
    // is therefore equivalent to just calling the [Dial] function.
    //
    // It is safe to call Dialer's methods concurrently.
    type Dialer struct {
    	// Timeout is the maximum amount of time a dial will wait for
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  5. src/net/server_test.go

    					t.Fatal(err)
    				}
    			}
    
    			var trchs []chan error
    			for i := 0; i < N; i++ {
    				_, port, err := SplitHostPort(lss[i].Listener.Addr().String())
    				if err != nil {
    					t.Fatal(err)
    				}
    				d := Dialer{Timeout: someTimeout}
    				c, err := d.Dial(tt.tnet, JoinHostPort(tt.taddr, port))
    				if err != nil {
    					if perr := parseDialError(err); perr != nil {
    						t.Error(perr)
    					}
    					t.Fatal(err)
    				}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    		toDial = strings.Replace(toDial, "https://", "wss://", 1)
    		toDial += RoutePath
    
    		dialer := ws.DefaultDialer
    		dialer.ReadBufferSize = readBufferSize
    		dialer.WriteBufferSize = writeBufferSize
    		dialer.Timeout = defaultDialTimeout
    		if c.dialer != nil {
    			dialer.NetDial = c.dialer.DialContext
    		}
    		if c.header == nil {
    			c.header = make(http.Header, 2)
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  7. cmd/kube-apiserver/app/server.go

    		// Use the config.ControlPlane.Generic.EgressSelector lookup to find the dialer to connect to the kubelet
    		config.Extra.KubeletClientConfig.Lookup = config.ControlPlane.Generic.EgressSelector.Lookup
    
    		// Use the config.ControlPlane.Generic.EgressSelector lookup as the transport used by the "proxy" subresources.
    		networkContext := egressselector.Cluster.AsNetworkContext()
    		dialer, err := config.ControlPlane.Generic.EgressSelector.Lookup(networkContext)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 17:44:20 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. internal/grid/manager.go

    	local string
    
    	// Validate incoming requests.
    	authRequest func(r *http.Request) error
    }
    
    // ManagerOptions are options for creating a new grid manager.
    type ManagerOptions struct {
    	Dialer       ContextDialer               // Outgoing dialer.
    	Local        string                      // Local host name.
    	Hosts        []string                    // All hosts, including local in the grid.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    			grpc.WithStreamInterceptor(otelgrpc.StreamClientInterceptor(tracingOpts...)))
    	}
    	if egressDialer != nil {
    		dialer := func(ctx context.Context, addr string) (net.Conn, error) {
    			if strings.Contains(addr, "//") {
    				// etcd client prior to 3.5 passed URLs to dialer, normalize to address
    				u, err := url.Parse(addr)
    				if err != nil {
    					return nil, err
    				}
    				addr = u.Host
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  10. src/net/lookup.go

    	// not enabled by default because it may affect compatibility
    	// with resolvers that process AAAA queries incorrectly.
    	StrictErrors bool
    
    	// Dial optionally specifies an alternate dialer for use by
    	// Go's built-in DNS resolver to make TCP and UDP connections
    	// to DNS services. The host in the address parameter will
    	// always be a literal IP address and not a host name, and the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 28.6K bytes
    - Viewed (0)
Back to top