Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewHTTPTransportWithTimeout (0.76 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 17:51:53 UTC 2025
    - 6.5K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  4. cmd/config-current.go

    		if err != nil {
    			configLogIf(ctx, fmt.Errorf("Invalid api configuration: %w", err))
    		}
    
    		globalAPIConfig.init(apiConfig, setDriveCounts, objAPI.Legacy())
    		setRemoteInstanceTransport(NewHTTPTransportWithTimeout(apiConfig.RemoteTransportDeadline))
    	case config.CompressionSubSys:
    		cmpCfg, err := compress.LookupConfig(s[config.CompressionSubSys][config.Default])
    		if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
Back to top