Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for DialContext (0.05 sec)

  1. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. 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,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 17:51:53 UTC 2025
    - 6.5K bytes
    - Viewed (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
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 2.6K bytes
    - Viewed (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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (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{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Nov 11 14:51:43 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. internal/grid/connection_test.go

    		})
    	}
    	connReady := make(chan struct{})
    	// We fake a local and remote server.
    	localHost := hosts[0]
    	remoteHost := hosts[1]
    	local, err := NewManager(t.Context(), ManagerOptions{
    		Dialer: ConnectWS(dialer.DialContext,
    			dummyNewToken,
    			nil),
    		Local:        localHost,
    		Hosts:        hosts,
    		AuthFn:       dummyNewToken,
    		AuthToken:    dummyTokenValidate,
    		BlockConnect: connReady,
    	})
    	errFatal(err)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  7. internal/grid/debug.go

    	ready := make(chan struct{})
    	ctx, cancel := context.WithCancel(context.Background())
    	res.cancel = cancel
    	for i, host := range hosts {
    		manager, err := NewManager(ctx, ManagerOptions{
    			Dialer: ConnectWS(dialer.DialContext,
    				dummyNewToken,
    				nil),
    			Local:        host,
    			Hosts:        hosts,
    			AuthFn:       dummyNewToken,
    			AuthToken:    dummyTokenValidate,
    			BlockConnect: ready,
    			RoutePath:    RoutePath,
    		})
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  8. 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
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Jul 17 02:15:01 UTC 2020
    - 7.6K bytes
    - Viewed (0)
Back to top