Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewInternodeDialContext (0.13 sec)

  1. internal/http/dial_others.go

    }
    
    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    // NewInternodeDialContext configures a custom dialer for internode communications
    func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. internal/http/dial_linux.go

    }
    
    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    // NewInternodeDialContext setups a custom dialer for internode communication
    func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. cmd/grid.go

    		// provide any DriveOPTimeout() function, as that is not
    		// useful over persistent connections.
    		Dialer: grid.ConnectWS(
    			grid.ContextDialer(xhttp.DialContextWithLookupHost(lookupHost, xhttp.NewInternodeDialContext(rest.DefaultTimeout, globalTCPOptions.ForWebsocket()))),
    			newCachedAuthToken(),
    			&tls.Config{
    				RootCAs:          globalRootCAs,
    				CipherSuites:     fips.TLSCiphers(),
    				CurvePreferences: fips.TLSCurveIDs(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  4. internal/http/transports.go

    	if maxIdleConnsPerHost <= 0 {
    		maxIdleConnsPerHost = 1024
    	}
    
    	dialContext := s.DialContext
    	if dialContext == nil {
    		dialContext = DialContextWithLookupHost(s.LookupHost, NewInternodeDialContext(s.DialTimeout, s.TCPOptions))
    	}
    
    	tlsClientConfig := tls.Config{
    		RootCAs:            s.RootCAs,
    		CipherSuites:       s.CipherSuites,
    		CurvePreferences:   s.CurvePreferences,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. cmd/update.go

    }
    
    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,
    		TLSClientConfig: &tls.Config{
    			RootCAs:            globalRootCAs,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
Back to top