Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for NumNodes (0.25 sec)

  1. pkg/scheduler/internal/cache/node_tree.go

    // over nodes in a round robin fashion.
    func (nt *nodeTree) list() ([]string, error) {
    	if len(nt.zones) == 0 {
    		return nil, nil
    	}
    	nodesList := make([]string, 0, nt.numNodes)
    	numExhaustedZones := 0
    	nodeIndex := 0
    	for len(nodesList) < nt.numNodes {
    		if numExhaustedZones >= len(nt.zones) { // all zones are exhausted.
    			return nodesList, errors.New("all zones exhausted before reaching count of nodes expected")
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  2. samples/kind-lb/setupkind.sh

      exit 1
    fi
    
    if [[ "${MODE}" == "ambient" ]]; then
      NUMNODES=${NUMNODES:-2}
    fi
    
    NODES=$(cat <<-EOM
    nodes:
    - role: control-plane
    EOM
    )
    
    if [[ -n "${NUMNODES}" ]]; then
    for _ in $(seq 1 "${NUMNODES}"); do
      NODES+=$(printf "\n%s" "- role: worker")
    done
    fi
    
    CONFIG=$(cat <<-EOM
    kind: Cluster
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Oct 02 19:08:19 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    // candidates returned will never be greater than <numNodes>.
    func (pl *DefaultPreemption) calculateNumCandidates(numNodes int32) int32 {
    	n := (numNodes * pl.args.MinCandidateNodesPercentage) / 100
    	if n < pl.args.MinCandidateNodesAbsolute {
    		n = pl.args.MinCandidateNodesAbsolute
    	}
    	if n > numNodes {
    		n = numNodes
    	}
    	return n
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/node_tree_test.go

    	expectedNumNodes := int(0)
    	for _, na := range expectedTree {
    		expectedNumNodes += len(na)
    	}
    	if numNodes := nt.numNodes; numNodes != expectedNumNodes {
    		t.Errorf("unexpected nodeTree.numNodes. Expected: %v, Got: %v", expectedNumNodes, numNodes)
    	}
    	if diff := cmp.Diff(expectedTree, nt.tree); diff != "" {
    		t.Errorf("Unexpected node tree (-want, +got):\n%s", diff)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/cache/snapshot.go

    	return s
    }
    
    // StorageInfos returns a StorageInfoLister.
    func (s *Snapshot) StorageInfos() framework.StorageInfoLister {
    	return s
    }
    
    // NumNodes returns the number of nodes in the snapshot.
    func (s *Snapshot) NumNodes() int {
    	return len(s.nodeInfoList)
    }
    
    // List returns the list of nodes in the snapshot.
    func (s *Snapshot) List() ([]*framework.NodeInfo, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/cache/snapshot_test.go

    				"gcr.io/200:v1": sets.New("node-0"),
    			},
    			expected: map[string]*framework.ImageStateSummary{
    				"gcr.io/10:v1": {
    					Size:     int64(10 * mb),
    					NumNodes: 2,
    				},
    				"gcr.io/200:v1": {
    					Size:     int64(200 * mb),
    					NumNodes: 1,
    				},
    			},
    		},
    		{
    			node: &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{Name: "node-0"},
    				Status:     v1.NodeStatus{},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 12K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor.go

    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    	return m
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go

    	tests := []struct {
    		Name      string
    		Pod       *v1.Pod
    		NumPV     int
    		NumPVC    int
    		NumNodes  int
    		PreFilter bool
    	}{
    		{
    			Name:      "with prefilter",
    			Pod:       createPodWithVolume("pod_0", "PVC_Stable_0"),
    			NumPV:     1000,
    			NumPVC:    1000,
    			NumNodes:  1000,
    			PreFilter: true,
    		},
    		{
    			Name:      "without prefilter",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 05:17:04 UTC 2023
    - 20K bytes
    - Viewed (0)
  9. pkg/scheduler/internal/cache/cache.go

    	snapshot.havePodsWithRequiredAntiAffinityNodeInfoList = make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes)
    	snapshot.usedPVCSet = sets.New[string]()
    	if updateAll {
    		// Take a snapshot of the nodes order in the tree
    		snapshot.nodeInfoList = make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes)
    		nodesList, err := cache.nodeTree.list()
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  10. pkg/scheduler/internal/cache/cache_test.go

    	if len(snapshot.nodeInfoList) != cache.nodeTree.numNodes {
    		return fmt.Errorf("unexpected number of nodes in NodeInfoList. Expected: %v, got: %v", cache.nodeTree.numNodes, len(snapshot.nodeInfoList))
    	}
    
    	expectedNodeInfoList := make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes)
    	expectedHavePodsWithAffinityNodeInfoList := make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes)
    	expectedUsedPVCSet := sets.New[string]()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
Back to top