- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for dialTimeout (0.24 sec)
-
internal/http/transports.go
var tlsClientSessionCacheSize = 100 // ConnSettings - contains connection settings. type ConnSettings struct { DialContext DialContext // Custom dialContext, DialTimeout is ignored if this is already setup. LookupHost LookupHost // Custom lookupHost, is nil on containerized deployments. DialTimeout time.Duration // TLS Settings RootCAs *x509.CertPool CipherSuites []uint16 CurvePreferences []tls.CurveID // HTTP2
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 00:50:37 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/http/dial_linux.go
// NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, Control: setTCPParametersFn(opts), } return dialer.DialContext(ctx, network, addr) } }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Jun 07 16:53:05 GMT 2023 - 4.4K bytes - Viewed (2) -
internal/http/dial_others.go
// NewCustomDialContext configures a custom dialer for internode communications func NewCustomDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, } return dialer.DialContext(ctx, network, addr) }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/utils.go
func GetDefaultConnSettings() xhttp.ConnSettings { lookupHost := globalDNSCache.LookupHost if IsKubernetes() || IsDocker() { lookupHost = nil } return xhttp.ConnSettings{ LookupHost: lookupHost, DialTimeout: rest.DefaultTimeout, RootCAs: globalRootCAs, TCPOptions: globalTCPOptions, } } // NewInternodeHTTPTransport returns a transport for internode MinIO // connections.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Mar 06 11:43:16 GMT 2024 - 32.6K bytes - Viewed (0) -
internal/config/etcd/etcd.go
if endpoints == "" { return cfg, nil } etcdEndpoints, etcdSecure, err := parseEndpoints(endpoints) if err != nil { return cfg, err } cfg.Enabled = true cfg.DialTimeout = defaultDialTimeout cfg.DialKeepAliveTime = defaultDialKeepAlive // Disable etcd client SDK logging, etcd client // incorrectly starts logging in unexpected data // format. cfg.LogConfig = &zap.Config{
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Producer.Return.Errors = true sconfig.Producer.RequiredAcks = 1 sconfig.Producer.Timeout = (10 * time.Second) sconfig.Net.ReadTimeout = (10 * time.Second) sconfig.Net.DialTimeout = (10 * time.Second) sconfig.Net.WriteTimeout = (10 * time.Second) sconfig.Metadata.Retry.Max = 1 sconfig.Metadata.Retry.Backoff = (10 * time.Second) sconfig.Metadata.RefreshFrequency = (15 * time.Minute)
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
internal/event/target/webhook.go
} // Store returns any underlying store if set. func (target *WebhookTarget) Store() event.TargetStore { return target.store } func (target *WebhookTarget) isActive() (bool, error) { conn, err := net.DialTimeout("tcp", target.addr, 5*time.Second) if err != nil { if xnet.IsNetworkOrHostDown(err, false) { return false, store.ErrNotConnected } return false, err } defer conn.Close() return true, nil
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/event/target/kafka.go
if ok { config.Producer.Compression = cc config.Producer.CompressionLevel = args.Producer.CompressionLevel } config.Net.ReadTimeout = (5 * time.Second) config.Net.DialTimeout = (5 * time.Second) config.Net.WriteTimeout = (5 * time.Second) config.Metadata.Retry.Max = 1 config.Metadata.Retry.Backoff = (1 * time.Second) config.Metadata.RefreshFrequency = (15 * time.Minute)
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
}() closer := func() { cmd.Process.Kill() <-errChan } // Dial localhost:3222 to ensure the proxy is ready. delay := time.Second / 4 for attempt := 0; attempt < 5; attempt++ { conn, err := net.DialTimeout("tcp", "localhost:3222", 5*time.Second) if err == nil { conn.Close() return closer, nil } select { case <-time.After(delay): delay *= 2 case err := <-errChan: return nil, err
Go - Registered: Tue Mar 26 11:13:08 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
api/go1.txt
pkg net, func Dial(string, string) (Conn, error) pkg net, func DialIP(string, *IPAddr, *IPAddr) (*IPConn, error) pkg net, func DialTCP(string, *TCPAddr, *TCPAddr) (*TCPConn, error) pkg net, func DialTimeout(string, string, time.Duration) (Conn, error) pkg net, func DialUDP(string, *UDPAddr, *UDPAddr) (*UDPConn, error) pkg net, func DialUnix(string, *UnixAddr, *UnixAddr) (*UnixConn, error)
Plain Text - Registered: Tue Mar 26 11:13:08 GMT 2024 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Viewed (1)