- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for DialContext (0.05 sec)
-
internal/http/dial_others.go
return nil } } // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext configures a custom dialer for internode communications func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 24 04:08:47 UTC 2024 - 1.6K bytes - Viewed (0) -
internal/http/transports.go
TCPOptions TCPOptions } func (s ConnSettings) getDefaultTransport(maxIdleConnsPerHost int) *http.Transport { if maxIdleConnsPerHost <= 0 { maxIdleConnsPerHost = 1024 } dialContext := s.DialContext if dialContext == nil { dialContext = DialContextWithLookupHost(s.LookupHost, NewInternodeDialContext(s.DialTimeout, s.TCPOptions)) } tlsClientConfig := tls.Config{ RootCAs: s.RootCAs,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 08 17:51:53 UTC 2025 - 6.5K bytes - Viewed (0) -
internal/http/dial_dnscache.go
// // You can use returned dial function for `http.Transport.DialContext`. // // In this function, it uses functions from `rand` package. To make it really random, // you MUST call `rand.Seed` and change the value from the default in your application func DialContextWithLookupHost(lookupHost LookupHost, baseDialCtx DialContext) DialContext { if lookupHost == nil { lookupHost = net.DefaultResolver.LookupHost }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 2.6K bytes - Viewed (0) -
internal/http/dial_linux.go
} } }) return nil } } // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
for _, setter := range setters { setter(args) } args.httpClient = &http.Client{ Transport: &http.Transport{ Proxy: http.ProxyFromEnvironment, DialContext: (&net.Dialer{ Timeout: 3 * time.Second, KeepAlive: 5 * time.Second, }).DialContext, ResponseHeaderTimeout: 3 * time.Second, TLSHandshakeTimeout: 3 * time.Second, ExpectContinueTimeout: 3 * time.Second, TLSClientConfig: &tls.Config{Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Nov 11 14:51:43 UTC 2024 - 6.6K bytes - Viewed (0) -
internal/grid/connection_test.go
}) } connReady := make(chan struct{}) // We fake a local and remote server. localHost := hosts[0] remoteHost := hosts[1] local, err := NewManager(t.Context(), ManagerOptions{ Dialer: ConnectWS(dialer.DialContext, dummyNewToken, nil), Local: localHost, Hosts: hosts, AuthFn: dummyNewToken, AuthToken: dummyTokenValidate, BlockConnect: connReady, }) errFatal(err)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 5.9K bytes - Viewed (0) -
internal/grid/debug.go
ready := make(chan struct{}) ctx, cancel := context.WithCancel(context.Background()) res.cancel = cancel for i, host := range hosts { manager, err := NewManager(ctx, ManagerOptions{ Dialer: ConnectWS(dialer.DialContext, dummyNewToken, nil), Local: host, Hosts: hosts, AuthFn: dummyNewToken, AuthToken: dummyTokenValidate, BlockConnect: ready, RoutePath: RoutePath, })
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 4.4K bytes - Viewed (0) -
api/go1.7.txt
pkg io, const SeekStart = 0 pkg io, const SeekStart ideal-int pkg math/big, method (*Float) GobDecode([]uint8) error pkg math/big, method (*Float) GobEncode() ([]uint8, error) pkg net, method (*Dialer) DialContext(context.Context, string, string) (Conn, error) pkg net/http, const StatusAlreadyReported = 208 pkg net/http, const StatusAlreadyReported ideal-int pkg net/http, const StatusFailedDependency = 424
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Jun 28 15:08:11 UTC 2016 - 13.6K bytes - Viewed (0) -
api/go1.15.txt
pkg crypto/rsa, method (*PublicKey) Equal(crypto.PublicKey) bool pkg crypto/tls, method (*Dialer) Dial(string, string) (net.Conn, error) pkg crypto/tls, method (*Dialer) DialContext(context.Context, string, string) (net.Conn, error) pkg crypto/tls, method (ClientAuthType) String() string pkg crypto/tls, method (CurveID) String() string pkg crypto/tls, method (SignatureScheme) String() string
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Jul 17 02:15:01 UTC 2020 - 7.6K bytes - Viewed (0) -
internal/rest/client.go
} // The host's colon:port should be normalized. See Issue 14836. u.Host = removeEmptyPort(u.Host) // Transport is exactly same as Go default in https://golang.org/pkg/net/http/#RoundTripper // except custom DialContext and TLSClientConfig. clnt := &Client{ httpClient: &http.Client{Transport: tr}, url: u, auth: auth, connected: connected,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 14.7K bytes - Viewed (0)