Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 24 of 24 for globalEndpoints (0.09 sec)

  1. cmd/endpoint.go

    		return nodes[i].Host < nodes[j].Host
    	})
    	return
    }
    
    // GetPoolIdx return pool index
    func (l EndpointServerPools) GetPoolIdx(pool string) int {
    	for id, ep := range globalEndpoints {
    		if ep.CmdLine != pool {
    			continue
    		}
    		return id
    	}
    	return -1
    }
    
    // GetLocalPoolIdx returns the pool which endpoint belongs to locally.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	r := http.Request{Host: globalLocalNodeName}
    	metrics, err := strconv.ParseBool(params.Get(peerRESTMetrics))
    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    	info := getLocalServerProperty(globalEndpoints, &r, metrics)
    	return madminServerProperties.NewJSONWith(&info), nil
    }
    
    // GetCPUsHandler - returns CPU info.
    func (s *peerRESTServer) GetCPUsHandler(_ *grid.MSS) (*grid.JSON[madmin.CPUs], *grid.RemoteErr) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    	randomWait := func() time.Duration {
    		// randomWait depends on the number of nodes to avoid triggering resume and cleanups at the same time.
    		return time.Duration(rand.Float64() * float64(time.Duration(globalEndpoints.NEndpoints())*time.Hour))
    	}
    
    	go func() {
    		jpool.resume(randomWait)
    		jpool.cleanupReports(randomWait)
    	}()
    
    	return jpool
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    	globalEndpoints = EndpointServerPools{}
    }
    
    func resetGlobalIsErasure() {
    	globalIsErasure = false
    }
    
    // reset global heal state
    func resetGlobalHealState() {
    	// Init global heal state
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top