- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 977 for dial (0.17 sec)
-
src/net/dial.go
// When using TCP, and the host resolves to multiple IP addresses, // Dial will try each IP address in order until one succeeds. // // Examples: // // Dial("tcp", "golang.org:http") // Dial("tcp", "192.0.2.1:http") // Dial("tcp", "198.51.100.1:80") // Dial("udp", "[2001:db8::1]:domain") // Dial("udp", "[fe80::1%lo0]:53") // Dial("tcp", ":80") // // For IP networks, the network must be "ip", "ip4" or "ip6" followed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/dial.go
"crypto/tls" "fmt" "net" "net/http" "net/url" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/third_party/forked/golang/netutil" "k8s.io/klog/v2" ) // DialURL will dial the specified URL using the underlying dialer held by the passed // RoundTripper. The primary use of this method is to support proxying upgradable connections.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/metrics/metrics.go
// StageConnect indicates that the dial failed at establishing connection to the proxy server. StageConnect = "connect" // StageProxy indicates that the dial failed at requesting the proxy server to proxy. StageProxy = "proxy" ) var ( // Use buckets ranging from 5 ms to 12.5 seconds. latencyBuckets = []float64{0.005, 0.025, 0.1, 0.5, 2.5, 12.5} // Metrics provides access to all dial metrics. Metrics = newDialMetrics() )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 01 23:36:51 UTC 2022 - 4.3K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
} // wantDial waits for the Transport to start a Dial. func (dt *transportDialTester) wantDial() *transportDialTesterConn { c := <-dt.dials c.connID = dt.dialCount dt.dialCount++ dt.t.Logf("Dial %v: started", c.connID) return c } // finish completes a Dial. func (c *transportDialTesterConn) finish(err error) { c.t.Logf("Dial %v: finished (err:%v)", c.connID, err) c.ready <- err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/dial_test.go
}, "insecure, custom dial": { TLSConfig: &tls.Config{InsecureSkipVerify: true}, Dial: d.DialContext, }, "secure, no roots, custom dial": { TLSConfig: &tls.Config{InsecureSkipVerify: false}, Dial: d.DialContext, ExpectError: "unknown authority|not trusted", }, "secure with roots, custom dial": { TLSConfig: &tls.Config{InsecureSkipVerify: false, RootCAs: roots},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 8.4K bytes - Viewed (0) -
src/net/net_fake_test.go
// all 65535 valid (fake) ports. The listener is already using one, so // we should be able to Dial the remaining 65534. for len(dialed) < (1<<16)-2 { c, err := Dial(ln.Addr().Network(), ln.Addr().String()) if err != nil { t.Fatalf("unexpected error from Dial with %v connections: %v", len(dialed), err) } dialed = append(dialed, c) if testing.Verbose() && len(dialed)%(1<<12) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.8K 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/test/echo/common/dialer.go
) var ( // DefaultGRPCDialFunc just calls grpc.Dial directly, with no alterations to the arguments. DefaultGRPCDialFunc = grpc.DialContext // DefaultWebsocketDialFunc just calls dialer.Dial, with no alterations to the arguments. DefaultWebsocketDialFunc = func(dialer *websocket.Dialer, urlStr string, requestHeader http.Header) (*websocket.Conn, *http.Response, error) { return dialer.Dial(urlStr, requestHeader) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Aug 07 15:55:42 UTC 2020 - 3K bytes - Viewed (0) -
src/net/dial_unix_test.go
if err == nil { c.Close() t.Fatal("unexpected successful dial; want context canceled error") } 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 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 2.8K bytes - Viewed (0) -
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)