Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for GetProxyEndpointLocalIndex (0.2 sec)

  1. cmd/admin-heal-ops.go

    			ClientToken: "unknown",
    			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()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  2. cmd/endpoint.go

    			return net.JoinHostPort(host, port)
    		}
    
    		return net.JoinHostPort("127.0.0.1", port)
    	}
    	return peerSet.ToSlice()[0]
    }
    
    // GetProxyEndpointLocalIndex returns index of the local proxy endpoint
    func GetProxyEndpointLocalIndex(proxyEps []ProxyEndpoint) int {
    	for i, pep := range proxyEps {
    		if pep.IsLocal {
    			return i
    		}
    	}
    	return -1
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 34.4K bytes
    - Viewed (0)
  3. 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)
  4. cmd/admin-handlers.go

    		if exists && !nh.hasEnded() && len(nh.currentStatus.Items) > 0 {
    			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,
    			})
    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