Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for dialTimeout (0.21 sec)

  1. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 00:50:37 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  2. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jun 07 16:53:05 GMT 2023
    - 4.4K bytes
    - Viewed (3)
  3. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  4. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  5. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
Back to top