Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewInternodeHTTPTransport (0.26 sec)

  1. internal/http/transports.go

    	// 		// requesting compression with an "Accept-Encoding: gzip"
    	// 		trhttp2.DisableCompression = true
    	// 	}
    	// }
    
    	return tr
    }
    
    // NewInternodeHTTPTransport returns transport for internode MinIO connections.
    func (s ConnSettings) NewInternodeHTTPTransport(maxIdleConnsPerHost int) func() http.RoundTripper {
    	tr := s.getDefaultTransport(maxIdleConnsPerHost)
    
    	// Settings specific to internode requests.
    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

    		LookupHost:  globalDNSCache.LookupHost,
    		DialTimeout: rest.DefaultTimeout,
    		RootCAs:     globalRootCAs,
    		TCPOptions:  globalTCPOptions,
    	}
    }
    
    // NewInternodeHTTPTransport returns a transport for internode MinIO
    // connections.
    func NewInternodeHTTPTransport(maxIdleConnsPerHost int) func() http.RoundTripper {
    	return xhttp.ConnSettings{
    		LookupHost:       globalDNSCache.LookupHost,
    		DialTimeout:      rest.DefaultTimeout,
    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. cmd/server-main.go

    		SendBufSize: ctxt.SendBufSize,
    		RecvBufSize: ctxt.RecvBufSize,
    	}
    
    	// allow transport to be HTTP/1.1 for proxying.
    	globalProxyEndpoints = GetProxyEndpoints(globalEndpoints)
    	globalInternodeTransport = NewInternodeHTTPTransport(ctxt.MaxIdleConnsPerHost)()
    	globalRemoteTargetTransport = NewRemoteTargetHTTPTransport(false)()
    	globalForwarder = handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  4. cmd/test-utils_test.go

    	setMaxResources(serverCtxt{})
    
    	// Initialize globalConsoleSys system
    	globalConsoleSys = NewConsoleLogger(context.Background(), io.Discard)
    
    	globalInternodeTransport = NewInternodeHTTPTransport(0)()
    
    	initHelp()
    
    	resetTestGlobals()
    
    	globalIsCICD = true
    
    	os.Exit(m.Run())
    }
    
    // concurrency level for certain parallel tests.
    const testConcurrencyLevel = 10
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top