Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for DialContext (0.2 sec)

  1. internal/http/dial_others.go

    	return func(network, address string, c syscall.RawConn) error {
    		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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  2. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jun 07 16:53:05 GMT 2023
    - 4.4K bytes
    - Viewed (3)
  3. 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,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 00:50:37 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  4. 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
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jul 03 19:30:51 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  5. 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(context.Background(), ManagerOptions{
    		Dialer:       dialer.DialContext,
    		Local:        localHost,
    		Hosts:        hosts,
    		AddAuth:      func(aud string) string { return aud },
    		AuthRequest:  dummyRequestValidate,
    		BlockConnect: connReady,
    	})
    	errFatal(err)
    
    	// 1: Echo
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 6K bytes
    - Viewed (0)
  6. cni/pkg/pluginlistener/listener_test.go

    	var opts []grpc.DialOption
    
    	opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) {
    		var d net.Dialer
    		return d.DialContext(ctx, "unix", socket)
    	}))
    
    	conn, err := grpc.Dial(socket, opts...)
    	if err != nil {
    		return nil, err
    	}
    
    	return conn, nil
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 21:58:32 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  7. 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{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  8. 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: dialer.DialContext,
    			Local:  host,
    			Hosts:  hosts,
    			AuthRequest: func(r *http.Request) error {
    				return nil
    			},
    			AddAuth:      func(aud string) string { return aud },
    			BlockConnect: ready,
    		})
    		if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  9. cni/pkg/plugin/cnieventclient.go

    type CNIEventClient struct {
    	client *http.Client
    	url    string
    }
    
    func buildClient(address, path string) CNIEventClient {
    	c := &http.Client{
    		Transport: &http.Transport{
    			DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
    				return net.Dial("unix", address)
    			},
    		},
    		Timeout: 1000 * time.Millisecond,
    	}
    	eventC := CNIEventClient{
    		client: c,
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  10. 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
    Plain Text
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Tue Jun 28 15:08:11 GMT 2016
    - 13.6K bytes
    - Viewed (0)
Back to top