- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 129 for dialFn (0.2 sec)
-
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) -
pkg/uds/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 Dec 16 02:46:58 UTC 2021 - 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/net/iprawsock_plan9.go
return 0, syscall.EPLAN9 } func (c *IPConn) writeMsg(b, oob []byte, addr *IPAddr) (n, oobn int, err error) { return 0, 0, syscall.EPLAN9 } func (sd *sysDialer) dialIP(ctx context.Context, laddr, raddr *IPAddr) (*IPConn, error) { return nil, syscall.EPLAN9 } func (sl *sysListener) listenIP(ctx context.Context, laddr *IPAddr) (*IPConn, error) { return nil, syscall.EPLAN9
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 29 23:57:04 UTC 2018 - 874 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) -
staging/src/k8s.io/apimachinery/pkg/util/net/util_test.go
} } } type tcpLB struct { t *testing.T ln net.Listener serverURL string dials int32 } func (lb *tcpLB) handleConnection(in net.Conn, stopCh chan struct{}) { out, err := net.Dial("tcp", lb.serverURL) if err != nil { lb.t.Log(err) return } go io.Copy(out, in) go io.Copy(in, out) <-stopCh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 4.3K bytes - Viewed (0) -
src/log/syslog/syslog_test.go
if testing.Short() { t.Skip("skipping syslog test during -short") } f, err := Dial("", "", (LOG_LOCAL7|LOG_DEBUG)+1, "syslog_test") if f != nil { t.Fatalf("Should have trapped bad priority") } f, err = Dial("", "", -1, "syslog_test") if f != nil { t.Fatalf("Should have trapped bad priority") } l, err := Dial("", "", LOG_USER|LOG_ERR, "syslog_test") if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 12 16:09:24 UTC 2023 - 9.6K bytes - Viewed (0) -
pkg/hbone/server.go
w.(http.Flusher).Flush() ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() dst, err := (&net.Dialer{}).DialContext(ctx, "tcp", r.Host) if err != nil { w.WriteHeader(http.StatusServiceUnavailable) log.Errorf("failed to dial upstream: %v", err) return true } log.Infof("Connected to %v", r.Host) w.WriteHeader(http.StatusOK) wg := sync.WaitGroup{} wg.Add(1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 10 02:05:07 UTC 2022 - 2.4K bytes - Viewed (0) -
src/net/dial_unix_test.go
} select { case <-ctx.Done(): case <-time.After(5 * time.Second): t.Fatal("expected context to be canceled") } oe, ok := err.(*OpError) if !ok || oe.Op != "dial" { t.Fatalf("Dial error = %#v; want dial *OpError", err) } if oe.Err != errCanceled { t.Errorf("DialContext = (%v, %v); want OpError with error %v", c, err, errCanceled) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 2.8K bytes - Viewed (0)