Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 71 for dialFn (0.13 sec)

  1. src/net/udpsock_posix.go

    	ctrlCtxFn := sd.Dialer.ControlContext
    	if ctrlCtxFn == nil && sd.Dialer.Control != nil {
    		ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error {
    			return sd.Dialer.Control(network, address, c)
    		}
    	}
    	fd, err := internetSocket(ctx, sd.network, laddr, raddr, syscall.SOCK_DGRAM, 0, "dial", ctrlCtxFn)
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. cni/pkg/pluginlistener/listener_test.go

    	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
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 08 21:58:32 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go

    func NoOpNewStreamHandler(stream Stream, replySent <-chan struct{}) error { return nil }
    
    // Dialer knows how to open a streaming connection to a server.
    type Dialer interface {
    
    	// Dial opens a streaming connection to a server using one of the protocols
    	// specified (in order of most preferred to least preferred).
    	Dial(protocols ...string) (Connection, string, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  4. src/internal/nettrace/nettrace.go

    	// ConnectStart is called before a Dial, excluding Dials made
    	// during DNS lookups. In the case of DualStack (Happy Eyeballs)
    	// dialing, this may be called multiple times, from multiple
    	// goroutines.
    	ConnectStart func(network, addr string)
    
    	// ConnectDone is called after a Dial with the results, excluding
    	// Dials made during DNS lookups. It may also be called multiple
    	// times, like ConnectStart.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 11:57:14 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  5. src/net/main_test.go

    	// If external IPv4 connectivity exists, we can try dialing
    	// non-node/interface local scope IPv4 addresses.
    	// On Windows, Lookup APIs may not return IPv4-related
    	// resource records when a node has no external IPv4
    	// connectivity.
    	testIPv4 = flag.Bool("ipv4", true, "assume external IPv4 connectivity exists")
    
    	// If external IPv6 connectivity exists, we can try dialing
    	// non-node/interface local scope IPv6 addresses.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. src/internal/syscall/windows/security_windows.go

    }
    
    const SE_GROUP_INTEGRITY = 0x00000020
    
    type TokenType uint32
    
    const (
    	TokenPrimary       TokenType = 1
    	TokenImpersonation TokenType = 2
    )
    
    //sys	GetProfilesDirectory(dir *uint16, dirLen *uint32) (err error) = userenv.GetProfilesDirectoryW
    
    const (
    	LG_INCLUDE_INDIRECT  = 0x1
    	MAX_PREFERRED_LENGTH = 0xFFFFFFFF
    )
    
    type LocalGroupUserInfo0 struct {
    	Name *uint16
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 04 07:21:38 UTC 2023
    - 4K bytes
    - Viewed (0)
  7. docs/id/docs/tutorial/index.md

    Ini juga dibangun untuk digunakan sebagai referensi yang akan datang.
    
    Sehingga kamu dapat kembali lagi dan mencari apa yang kamu butuhkan dengan tepat.
    
    ## Jalankan kode
    
    Semua blok-blok kode dapat disalin dan digunakan langsung (Mereka semua sebenarnya adalah file python yang sudah teruji).
    
    Untuk menjalankan setiap contoh, salin kode ke file `main.py`, dan jalankan `uvicorn` dengan:
    
    <div class="termy">
    
    ```console
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. pkg/kube/portforwarder.go

    	if err != nil {
    		return nil, fmt.Errorf("failure creating roundtripper: %v", err)
    	}
    
    	dialer := spdy.NewDialer(upgrader, &http.Client{Transport: roundTripper}, http.MethodPost, serverURL)
    
    	fw, err := portforward.NewOnAddresses(dialer,
    		[]string{f.localAddress},
    		[]string{fmt.Sprintf("%d:%d", f.localPort, f.podPort)},
    		f.stopCh,
    		readyCh,
    		io.Discard,
    		os.Stderr)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 02:12:37 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  9. src/net/http/httptrace/trace.go

    	// ConnectStart is called when a new connection's Dial begins.
    	// If net.Dialer.DualStack (IPv6 "Happy Eyeballs") support is
    	// enabled, this may be called multiple times.
    	ConnectStart func(network, addr string)
    
    	// ConnectDone is called when a new connection's Dial
    	// completes. The provided err indicates whether the
    	// connection completed successfully.
    	// If net.Dialer.DualStack ("Happy Eyeballs") support is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. src/net/http/httputil/dump.go

    	// custom dialer that returns a fake net.Conn that waits
    	// for the full input (and recording it), and then responds
    	// with a dummy response.
    	var buf bytes.Buffer // records the output
    	pr, pw := io.Pipe()
    	defer pr.Close()
    	defer pw.Close()
    	dr := &delegateReader{c: make(chan io.Reader)}
    
    	t := &http.Transport{
    		Dial: func(net, addr string) (net.Conn, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 9.3K bytes
    - Viewed (0)
Back to top