Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for RoundTripper (0.08 sec)

  1. cmd/globals.go

    	globalMRFState = newMRFState()
    
    	// If writes to FS backend should be O_SYNC.
    	globalFSOSync bool
    
    	globalProxyEndpoints []ProxyEndpoint
    
    	globalInternodeTransport http.RoundTripper
    
    	globalRemoteTargetTransport http.RoundTripper
    
    	globalDNSCache = &dnscache.Resolver{
    		Timeout: 5 * time.Second,
    	}
    
    	globalForwarder *handlers.Forwarder
    
    	globalTierConfigMgr *TierConfigMgr
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  2. cmd/sftp-server-driver.go

    		remoteIP:    remoteIP,
    	}
    	return sftp.Handlers{
    		FileGet:  handler,
    		FilePut:  handler,
    		FileCmd:  handler,
    		FileList: handler,
    	}
    }
    
    type forwardForTransport struct {
    	tr  http.RoundTripper
    	fwd string
    }
    
    func (f forwardForTransport) RoundTrip(r *http.Request) (*http.Response, error) {
    	r.Header.Set("X-Forwarded-For", f.fwd)
    	return f.tr.RoundTrip(r)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  3. cmd/update.go

    	releaseInfo = fields[1]
    
    	releaseTime, err = releaseInfoToReleaseTime(releaseInfo)
    	return sha256Sum, releaseTime, releaseInfo, err
    }
    
    func getUpdateTransport(timeout time.Duration) http.RoundTripper {
    	var updateTransport http.RoundTripper = &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		DialContext:           xhttp.NewInternodeDialContext(timeout, globalTCPOptions),
    		IdleConnTimeout:       timeout,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  4. cmd/ftp-server-driver.go

    	}
    	return subtle.ConstantTimeCompare([]byte(ui.Credentials.SecretKey), []byte(password)) == 1, nil
    }
    
    func (driver *ftpDriver) getMinIOClient(ctx *ftp.Context) (*minio.Client, error) {
    	tr := http.RoundTripper(globalRemoteFTPClientTransport)
    	if host, _, err := net.SplitHostPort(ctx.Sess.RemoteAddr().String()); err == nil {
    		tr = forwardForTransport{tr: tr, fwd: host}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  5. cmd/endpoint.go

    	URLEndpointType
    )
    
    // ProxyEndpoint - endpoint used for proxy redirects
    // See proxyRequest() for details.
    type ProxyEndpoint struct {
    	Endpoint
    	Transport http.RoundTripper
    }
    
    // Node holds information about a node in this cluster
    type Node struct {
    	*url.URL
    	Pools    []int
    	IsLocal  bool
    	GridHost string
    }
    
    // Endpoint - any type of endpoint.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  6. cmd/utils.go

    		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,
    		RootCAs:          globalRootCAs,
    		CipherSuites:     crypto.TLSCiphers(),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  7. cmd/handler-utils.go

    	// proxying the request to another node.
    	for k := range w.Header() {
    		w.Header().Del(k)
    	}
    
    	f := handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    			if err != nil && !errors.Is(err, context.Canceled) {
    				proxyLogIf(GlobalContext, err)
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  8. cmd/object-handlers.go

    }
    
    // getRemoteInstanceTransport contains a roundtripper for external (not peers) servers
    var remoteInstanceTransport atomic.Value
    
    func setRemoteInstanceTransport(tr http.RoundTripper) {
    	remoteInstanceTransport.Store(tr)
    }
    
    func getRemoteInstanceTransport() http.RoundTripper {
    	rt, ok := remoteInstanceTransport.Load().(http.RoundTripper)
    	if ok {
    		return rt
    	}
    	return nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  9. cmd/server-main.go

    	globalProxyEndpoints = GetProxyEndpoints(globalEndpoints, globalRemoteTargetTransport)
    
    	globalForwarder = handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: globalRemoteTargetTransport,
    		Logger: func(err error) {
    			if err != nil && !errors.Is(err, context.Canceled) {
    				proxyLogIf(GlobalContext, err)
    			}
    		},
    	})
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
Back to top