- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for NumNodes (0.11 sec)
-
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) -
samples/kind-lb/setupkind.sh
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 02 19:08:19 UTC 2023 - 7.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)