- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 156 for Dialer (0.45 sec)
-
pkg/hbone/server.go
// Send headers back immediately so we can start getting the body 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)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 10 02:05:07 UTC 2022 - 2.4K bytes - Viewed (0) -
internal/http/dial_dnscache.go
if lookupHost == nil { lookupHost = net.DefaultResolver.LookupHost } if baseDialCtx == nil { // This is same as which `http.DefaultTransport` uses. baseDialCtx = (&net.Dialer{ Timeout: 30 * time.Second, KeepAlive: 30 * time.Second, }).DialContext } return func(ctx context.Context, network, addr string) (conn net.Conn, err error) { host, port, err := net.SplitHostPort(addr)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jul 03 19:30:51 UTC 2023 - 2.6K bytes - Viewed (0) -
src/net/http/httptrace/trace.go
// 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/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) -
pkg/kubelet/pluginmanager/pluginwatcher/example_handler.go
grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock(), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) { return (&net.Dialer{}).DialContext(ctx, "unix", addr) }), ) if err != nil { return nil, nil, fmt.Errorf("failed to dial socket %s, err: %v", unixSocketPath, err) } return registerapi.NewRegistrationClient(c), c, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go
grpc.WithAuthority("localhost"), grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock(), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) { return (&net.Dialer{}).DialContext(ctx, "unix", addr) }), ) if err != nil { return nil, nil, fmt.Errorf(errFailedToDialDevicePlugin+" %v", err) } return api.NewDevicePluginClient(c), c, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0) -
test/stress/runstress.go
doParseGo = flag.Bool("parsego", true, "stress parsing Go (generates garbage)") ) func Println(a ...interface{}) { if *v { log.Println(a...) } } func dialStress(a net.Addr) { for { d := net.Dialer{Timeout: time.Duration(rand.Intn(1e9))} c, err := d.Dial("tcp", a.String()) if err == nil { Println("did dial") go func() { time.Sleep(time.Duration(rand.Intn(500)) * time.Millisecond) c.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:21:35 UTC 2024 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/tracing.go
if len(errs) > 0 { return fmt.Errorf("failed to validate tracing configuration: %v", errs.ToAggregate()) } opts := []otlptracegrpc.Option{} if es != nil { // Only use the egressselector dialer if egressselector is enabled. // Endpoint is on the "ControlPlane" network egressDialer, err := es.Lookup(egressselector.ControlPlane.AsNetworkContext()) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 21:39:39 UTC 2023 - 4.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
conn, err := grpc.Dial( p.endpoint, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, target string) (net.Conn, error) { return (&net.Dialer{}).DialContext(ctx, network, target) }), ) if err != nil { return nil, err } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0) -
src/net/sock_posix.go
// datagram connection, known as a datagram listener // // - An endpoint holder that opens an active stream or a // destination-specific datagram connection, known as a // dialer // // - An endpoint holder that opens the other connection, such // as talking to the protocol stack inside the kernel // // For stream and datagram listeners, they will only require
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6.3K bytes - Viewed (0)