Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for DialContext (0.06 seconds)

  1. internal/http/transports.go

    	TCPOptions TCPOptions
    }
    
    func (s ConnSettings) getDefaultTransport(maxIdleConnsPerHost int) *http.Transport {
    	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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 17:51:53 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. internal/http/dial_others.go

    		return nil
    	}
    }
    
    // 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  3. internal/http/dial_dnscache.go

    //
    // You can use returned dial function for `http.Transport.DialContext`.
    //
    // In this function, it uses functions from `rand` package. To make it really random,
    // you MUST call `rand.Seed` and change the value from the default in your application
    func DialContextWithLookupHost(lookupHost LookupHost, baseDialCtx DialContext) DialContext {
    	if lookupHost == nil {
    		lookupHost = net.DefaultResolver.LookupHost
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  4. internal/http/dial_linux.go

    				}
    			}
    		})
    		return nil
    	}
    }
    
    // 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 23 10:53:03 GMT 2024
    - 5K bytes
    - Click Count (0)
  5. internal/config/dns/operator_dns.go

    	for _, setter := range setters {
    		setter(args)
    	}
    	args.httpClient = &http.Client{
    		Transport: &http.Transport{
    			Proxy: http.ProxyFromEnvironment,
    			DialContext: (&net.Dialer{
    				Timeout:   3 * time.Second,
    				KeepAlive: 5 * time.Second,
    			}).DialContext,
    			ResponseHeaderTimeout: 3 * time.Second,
    			TLSHandshakeTimeout:   3 * time.Second,
    			ExpectContinueTimeout: 3 * time.Second,
    			TLSClientConfig: &tls.Config{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 11 14:51:43 GMT 2024
    - 6.6K bytes
    - Click Count (0)
  6. api/go1.7.txt

    pkg io, const SeekStart = 0
    pkg io, const SeekStart ideal-int
    pkg math/big, method (*Float) GobDecode([]uint8) error
    pkg math/big, method (*Float) GobEncode() ([]uint8, error)
    pkg net, method (*Dialer) DialContext(context.Context, string, string) (Conn, error)
    pkg net/http, const StatusAlreadyReported = 208
    pkg net/http, const StatusAlreadyReported ideal-int
    pkg net/http, const StatusFailedDependency = 424
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jun 28 15:08:11 GMT 2016
    - 13.6K bytes
    - Click Count (0)
  7. api/go1.15.txt

    pkg crypto/rsa, method (*PublicKey) Equal(crypto.PublicKey) bool
    pkg crypto/tls, method (*Dialer) Dial(string, string) (net.Conn, error)
    pkg crypto/tls, method (*Dialer) DialContext(context.Context, string, string) (net.Conn, error)
    pkg crypto/tls, method (ClientAuthType) String() string
    pkg crypto/tls, method (CurveID) String() string
    pkg crypto/tls, method (SignatureScheme) String() string
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Jul 17 02:15:01 GMT 2020
    - 7.6K bytes
    - Click Count (0)
  8. internal/rest/client.go

    	}
    	// The host's colon:port should be normalized. See Issue 14836.
    	u.Host = removeEmptyPort(u.Host)
    
    	// Transport is exactly same as Go default in https://golang.org/pkg/net/http/#RoundTripper
    	// except custom DialContext and TLSClientConfig.
    	clnt := &Client{
    		httpClient:               &http.Client{Transport: tr},
    		url:                      u,
    		auth:                     auth,
    		connected:                connected,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  9. 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{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  10. internal/grid/connection.go

    )
    
    // ContextDialer is a dialer that can be used to dial a remote.
    type ContextDialer func(ctx context.Context, network, address string) (net.Conn, error)
    
    // DialContext implements the Dialer interface.
    func (c ContextDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
    	return c(ctx, network, address)
    }
    
    const (
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
Back to Top