Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for globalProxyEndpoints (0.23 sec)

  1. cmd/admin-handlers-pools.go

    	// first node. The following is required to serialize (the effects of)
    	// concurrent rebalance-start commands.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    			if proxyEp.Endpoint.Host == ep.Host {
    				if proxyRequestByNodeIndex(ctx, w, r, nodeIdx) {
    					return
    				}
    			}
    		}
    	}
    
    	pools, ok := objectAPI.(*erasureServerPools)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/bucket-listobjects-handlers.go

    }
    
    func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int) (success bool) {
    	if len(globalProxyEndpoints) == 0 {
    		return false
    	}
    	if index < 0 || index >= len(globalProxyEndpoints) {
    		return false
    	}
    	ep := globalProxyEndpoints[index]
    	if ep.IsLocal {
    		return false
    	}
    	return proxyRequest(ctx, w, r, ep)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    			ClientToken: "unknown",
    			StartTime:   UTCNow(),
    		}
    	} else {
    		clientToken := he.clientToken
    		if globalIsDistErasure {
    			clientToken = fmt.Sprintf("%s:%d", he.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints))
    		}
    
    		hsp = madmin.HealStopSuccess{
    			ClientToken:   clientToken,
    			ClientAddress: he.clientAddress,
    			StartTime:     he.startTime,
    		}
    
    		he.stop()
    		for !he.hasEnded() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. cmd/globals.go

    	globalBackgroundHealState   = newHealState(GlobalContext, false)
    
    	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,
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  5. cmd/server-main.go

    		//		DriveOPTimeout: globalDriveConfig.GetOPTimeout,
    		Interface:   ctxt.Interface,
    		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)()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
Back to top