Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for globalProxyEndpoints (0.16 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 (1)
  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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. 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 (2)
  7. cmd/admin-handlers.go

    		if exists && !nh.hasEnded() && len(nh.currentStatus.Items) > 0 {
    			clientToken := nh.clientToken
    			if globalIsDistErasure {
    				clientToken = fmt.Sprintf("%s:%d", nh.clientToken, GetProxyEndpointLocalIndex(globalProxyEndpoints))
    			}
    			b, err := json.Marshal(madmin.HealStartSuccess{
    				ClientToken:   clientToken,
    				ClientAddress: nh.clientAddress,
    				StartTime:     nh.startTime,
    			})
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
Back to top