- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 71 for dialFn (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)