Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 129 for dialFn (0.19 sec)

  1. pkg/test/echo/server/forwarder/websocket.go

    		return newDialer(cfg).Dial(network, addr)
    	}
    	if len(cfg.UDS) > 0 {
    		dialContext = func(network, addr string) (net.Conn, error) {
    			return newDialer(cfg).Dial("unix", cfg.UDS)
    		}
    	}
    
    	dialer := &websocket.Dialer{
    		TLSClientConfig:  cfg.tlsConfig,
    		NetDial:          dialContext,
    		HandshakeTimeout: cfg.timeout,
    	}
    
    	conn, _, err := dialer.Dial(req.Url, wsReq)
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 11 16:27:16 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  2. internal/http/dial_dnscache.go

    // function. LookupHost may implement an internal DNS caching implementation, lookupHost
    // input if nil then net.DefaultResolver.LookupHost is used.
    //
    // It dials one by one and returns first connected `net.Conn`.
    // If it fails to dial all IPs from cache it returns first error. If no baseDialFunc
    // is given, it sets default dial function.
    //
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  3. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  4. pkg/client/tests/portfoward_test.go

    			if err != nil {
    				t.Fatal(err)
    			}
    			url, _ := url.Parse(server.URL)
    			dialer := spdy.NewDialer(upgrader, &http.Client{Transport: transport}, "POST", url)
    
    			stopChan := make(chan struct{}, 1)
    			readyChan := make(chan struct{})
    
    			pf, err := New(dialer, test.ports, stopChan, readyChan, os.Stdout, os.Stderr)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 05 06:08:18 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  5. src/runtime/testdata/testprognet/net.go

    import (
    	"fmt"
    	"net"
    )
    
    func init() {
    	registerInit("NetpollDeadlock", NetpollDeadlockInit)
    	register("NetpollDeadlock", NetpollDeadlock)
    }
    
    func NetpollDeadlockInit() {
    	fmt.Println("dialing")
    	c, err := net.Dial("tcp", "localhost:14356")
    	if err == nil {
    		c.Close()
    	} else {
    		fmt.Println("error: ", err)
    	}
    }
    
    func NetpollDeadlock() {
    	fmt.Println("done")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 01 23:34:33 UTC 2016
    - 539 bytes
    - Viewed (0)
  6. src/net/iprawsock.go

    }
    
    func newIPConn(fd *netFD) *IPConn { return &IPConn{conn{fd}} }
    
    // DialIP acts like [Dial] for IP networks.
    //
    // The network must be an IP network name; see func Dial for details.
    //
    // If laddr is nil, a local address is automatically chosen.
    // If the IP field of raddr is nil or an unspecified IP address, the
    // local system is assumed.
    func DialIP(network string, laddr, raddr *IPAddr) (*IPConn, error) {
    	if raddr == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. src/net/external_test.go

    		}
    	}
    }
    
    var dialGoogleTests = []struct {
    	dial               func(string, string) (Conn, error)
    	unreachableNetwork string
    	networks           []string
    	addrs              []string
    }{
    	{
    		dial:     (&Dialer{DualStack: true}).Dial,
    		networks: []string{"tcp", "tcp4", "tcp6"},
    		addrs:    []string{"www.google.com:http"},
    	},
    	{
    		dial:               Dial,
    		unreachableNetwork: "tcp6",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  8. src/net/iprawsock_test.go

    			}
    			a, err := ResolveIPAddr("ip", args[1])
    			if err != nil {
    				t.Errorf("ResolveIPAddr(\"ip\", %q) = %v", args[1], err)
    				continue
    			}
    			_, err = DialIP(args[0], nil, a)
    			if tt.shouldFail != (err != nil) {
    				t.Errorf("DialIP(%q, %v) = %v; want (err != nil) is %t", args[0], a, err, tt.shouldFail)
    			}
    			_, err = ListenIP(args[0], a)
    			if tt.shouldFail != (err != nil) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 6K bytes
    - Viewed (0)
  9. 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{
    			Timeout: dialTimeout,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  10. src/net/example_test.go

    	}
    }
    
    func ExampleDialer_unix() {
    	// DialUnix does not take a context.Context parameter. This example shows
    	// how to dial a Unix socket with a Context. Note that the Context only
    	// applies to the dial operation; it does not apply to the connection once
    	// it has been established.
    	var d net.Dialer
    	ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
    	defer cancel()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 13 16:36:59 UTC 2021
    - 8.5K bytes
    - Viewed (0)
Back to top