Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for DialTimeout (0.12 sec)

  1. internal/http/transports.go

    )
    
    // 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. internal/http/dial_others.go

    // NewInternodeDialContext configures a custom dialer for internode communications
    func NewInternodeDialContext(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)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. 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),
    		}
    		conn, err := dialer.DialContext(ctx, network, addr)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. cmd/utils.go

    	return etag
    }
    
    // GetDefaultConnSettings returns default HTTP connection settings.
    func GetDefaultConnSettings() xhttp.ConnSettings {
    	return xhttp.ConnSettings{
    		LookupHost:  globalDNSCache.LookupHost,
    		DialTimeout: rest.DefaultTimeout,
    		RootCAs:     globalRootCAs,
    		TCPOptions:  globalTCPOptions,
    	}
    }
    
    // NewInternodeHTTPTransport returns a transport for internode MinIO
    // connections.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  5. 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{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. 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)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. 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)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. 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)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top