Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 287 for dialFn (0.26 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/goaway_test.go

    		t.Run(tc.name, func(t *testing.T) {
    			// localAddr indicates how many TCP connection set up
    			localAddr := make([]string, 0)
    
    			// create the http client
    			dialFn := func(network, addr string, cfg *tls.Config) (conn net.Conn, err error) {
    				conn, err = tls.Dial(network, addr, cfg)
    				if err != nil {
    					t.Fatalf("unexpect connection err: %v", err)
    				}
    
    				localAddr = append(localAddr, conn.LocalAddr().String())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 17 12:58:54 UTC 2021
    - 13.9K bytes
    - Viewed (0)
  2. src/net/dial.go

    		*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)
  3. pkg/hbone/dialer.go

    	return nil
    }
    
    // TLSDialWithDialer is an implementation of tls.DialWithDialer that accepts a generic Dialer
    func TLSDialWithDialer(dialer Dialer, network, addr string, config *tls.Config) (*tls.Conn, error) {
    	return tlsDial(context.Background(), dialer, network, addr, config)
    }
    
    func tlsDial(ctx context.Context, netDialer Dialer, network, addr string, config *tls.Config) (*tls.Conn, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 24 15:56:41 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  4. pkg/test/echo/common/dialer.go

    		return client.Do(req)
    	}
    	// DefaultTCPDialFunc just calls dialer.Dial, with no alterations to the arguments.
    	DefaultTCPDialFunc = func(dialer net.Dialer, ctx context.Context, address string) (net.Conn, error) {
    		return dialer.DialContext(ctx, "tcp", address)
    	}
    	// DefaultDialer is provides defaults for all dial functions.
    	DefaultDialer = Dialer{
    		GRPC:      DefaultGRPCDialFunc,
    		Websocket: DefaultWebsocketDialFunc,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 07 15:55:42 UTC 2020
    - 3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    	}
    
    	return tlsConn, nil
    }
    
    // dialWithoutProxy dials the host specified by url, using TLS if appropriate.
    func (s *SpdyRoundTripper) dialWithoutProxy(ctx context.Context, url *url.URL) (net.Conn, error) {
    	dialAddr := netutil.CanonicalAddr(url)
    	dialer := s.Dialer
    	if dialer == nil {
    		dialer = &net.Dialer{}
    	}
    
    	if url.Scheme == "http" {
    		return dialer.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)
  6. staging/src/k8s.io/apimachinery/pkg/util/proxy/dial.go

    	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)
    		}
    		var d net.Dialer
    		return d.DialContext(ctx, "tcp", dialAddr)
    	case "https":
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. src/crypto/tls/tls.go

    //
    // DialWithDialer uses context.Background internally; to specify the context,
    // use [Dialer.DialContext] with NetDialer set to the desired dialer.
    func DialWithDialer(dialer *net.Dialer, network, addr string, config *Config) (*Conn, error) {
    	return dial(context.Background(), dialer, network, addr, config)
    }
    
    func dial(ctx context.Context, netDialer *net.Dialer, network, addr string, config *Config) (*Conn, error) {
    	if netDialer.Timeout != 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  8. src/net/dial_test.go

    	}
    
    	const fallbackDelay = 100 * time.Millisecond
    
    	var dialing sync.WaitGroup
    	dialing.Add(2)
    	origTestHookDialTCP := testHookDialTCP
    	defer func() { testHookDialTCP = origTestHookDialTCP }()
    	testHookDialTCP = func(ctx context.Context, net string, laddr, raddr *TCPAddr) (*TCPConn, error) {
    		// Wait until Happy Eyeballs kicks in and both connections are dialing,
    		// and inhibit cancellation.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
  9. pkg/kubelet/apis/podresources/client.go

    	addr, dialer, err := util.GetAddressAndDialer(socket)
    	if err != nil {
    		return nil, nil, err
    	}
    	ctx, cancel := context.WithTimeout(context.Background(), connectionTimeout)
    	defer cancel()
    
    	conn, err := grpc.DialContext(ctx, addr,
    		grpc.WithTransportCredentials(insecure.NewCredentials()),
    		grpc.WithContextDialer(dialer),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector_test.go

    				clientmetrics.Metrics.GetClientConnectionsMetric().WithLabelValues("dialing").Inc()
    			},
    			want: `
    # HELP konnectivity_network_proxy_client_client_connections Number of open client connections, by status (Example: dialing)
    # TYPE konnectivity_network_proxy_client_client_connections gauge
    konnectivity_network_proxy_client_client_connections{status="dialing"} 1
    `,
    		},
    	}
    	for _, tc := range testcases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 26 22:41:29 UTC 2023
    - 12.3K bytes
    - Viewed (0)
Back to top