Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewHTTPTransportWithTimeout (0.28 sec)

  1. internal/http/transports.go

    	// Settings specific to proxied requests.
    	tr.ResponseHeaderTimeout = 30 * time.Minute
    
    	return func() *http.Transport {
    		return tr
    	}
    }
    
    // NewHTTPTransportWithTimeout allows setting a timeout for response headers
    func (s ConnSettings) NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport {
    	tr := s.getDefaultTransport(0)
    
    	// Settings specific to this transport.
    	tr.ResponseHeaderTimeout = timeout
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/utils.go

    			return s.NewHTTPTransportWithTimeout(1 * time.Minute)
    		}
    		return transport
    	}
    
    	return globalRemoteTargetTransport
    }
    
    // NewHTTPTransport returns a new http configuration
    // used while communicating with the cloud backends.
    func NewHTTPTransport() *http.Transport {
    	return NewHTTPTransportWithTimeout(1 * time.Minute)
    }
    
    // Default values for dial timeout
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. internal/config/policy/plugin/config.go

    	if v := getCfg(EnableHTTP2); v != "" {
    		enableHTTP2, err = config.ParseBool(v)
    		if err != nil {
    			return args, err
    		}
    	}
    	httpSettings.EnableHTTP2 = enableHTTP2
    	transport := httpSettings.NewHTTPTransportWithTimeout(time.Minute)
    
    	args = Args{
    		URL:         u,
    		AuthToken:   getCfg(AuthToken),
    		Transport:   transport,
    		CloseRespFn: closeRespFn,
    	}
    	if err = args.Validate(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. cmd/config-current.go

    		autoGenerateRootCredentials() // Generate the KMS root credentials here since we don't know whether API root access is disabled until now.
    		setRemoteInstanceTransport(NewHTTPTransportWithTimeout(apiConfig.RemoteTransportDeadline))
    	case config.CompressionSubSys:
    		cmpCfg, err := compress.LookupConfig(s[config.CompressionSubSys][config.Default])
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
Back to top