Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for globalProxyEndpoints (1.09 sec)

  1. cmd/bucket-listobjects-handlers.go

    }
    
    func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int, returnErr bool) (proxied, success bool) {
    	if len(globalProxyEndpoints) == 0 {
    		return
    	}
    	if index < 0 || index >= len(globalProxyEndpoints) {
    		return
    	}
    	ep := globalProxyEndpoints[index]
    	if ep.IsLocal {
    		return
    	}
    	return true, proxyRequest(ctx, w, r, ep, returnErr)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 03 21:03:04 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  2. 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.Host == ep.Host {
    				if proxied, success := proxyRequestByNodeIndex(ctx, w, r, nodeIdx, false); proxied && success {
    					return
    				}
    			}
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  4. cmd/admin-heal-ops.go

    			StartTime:   UTCNow(),
    		}
    	} else {
    		clientToken := he.clientToken
    		if globalIsDistErasure {
    			clientToken = fmt.Sprintf("%s%s%d", he.clientToken, getKeySeparator(), GetProxyEndpointLocalIndex(globalProxyEndpoints))
    		}
    
    		hsp = madmin.HealStopSuccess{
    			ClientToken:   clientToken,
    			ClientAddress: he.clientAddress,
    			StartTime:     he.startTime,
    		}
    
    		he.stop()
    		for !he.hasEnded() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	job.ID = fmt.Sprintf("%s-%s%s%d", job.Type(), shortuuid.New(), getKeySeparator(), GetProxyEndpointLocalIndex(globalProxyEndpoints))
    	job.User = user
    	job.Started = time.Now()
    
    	if err := job.save(ctx, objectAPI); err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  6. cmd/server-main.go

    	}
    
    	// allow transport to be HTTP/1.1 for proxying.
    	globalInternodeTransport = NewInternodeHTTPTransport(ctxt.MaxIdleConnsPerHost)()
    	globalRemoteTargetTransport = NewRemoteTargetHTTPTransport(false)()
    	globalProxyEndpoints = GetProxyEndpoints(globalEndpoints, globalRemoteTargetTransport)
    
    	globalForwarder = handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: globalRemoteTargetTransport,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  7. cmd/admin-handlers.go

    			clientToken := nh.clientToken
    			if globalIsDistErasure {
    				clientToken = fmt.Sprintf("%s%s%d", nh.clientToken, getKeySeparator(), GetProxyEndpointLocalIndex(globalProxyEndpoints))
    			}
    			b, err := json.Marshal(madmin.HealStartSuccess{
    				ClientToken:   clientToken,
    				ClientAddress: nh.clientAddress,
    				StartTime:     nh.startTime,
    			})
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top