Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for seenNode (0.2 sec)

  1. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    		t.Run(test.name, func(t *testing.T) {
    			node := v1.Node{Status: v1.NodeStatus{Capacity: makeResources(10, 20, 32, 5, 20, 5), Allocatable: makeAllocatableResources(10, 20, 32, 5, 20, 5)}}
    			test.nodeInfo.SetNode(&node)
    
    			if test.args.ScoringStrategy == nil {
    				test.args.ScoringStrategy = defaultScoringStrategy
    			}
    
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    		tc.informerFactory.Shutdown()
    	})
    
    	tc.informerFactory.WaitForCacheSync(tc.ctx.Done())
    
    	for _, node := range nodes {
    		nodeInfo := framework.NewNodeInfo()
    		nodeInfo.SetNode(node)
    		tc.nodeInfos = append(tc.nodeInfos, nodeInfo)
    	}
    	tc.state = framework.NewCycleState()
    
    	return tc
    }
    
    // createReactor implements the logic required for the UID and ResourceVersion
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go

    				}
    			}
    		})
    	}
    }
    
    func TestPreFilterDisabled(t *testing.T) {
    	pod := &v1.Pod{}
    	nodeInfo := framework.NewNodeInfo()
    	node := v1.Node{}
    	nodeInfo.SetNode(&node)
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	p := plugintesting.SetupPluginWithInformers(ctx, t, New, &config.InterPodAffinityArgs{}, cache.NewEmptySnapshot(), nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 58.2K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/devicemanager/manager_test.go

    				// has no resource1 and two of resource2
    				v1.ResourceName(resourceName2): *resource.NewQuantity(int64(2), resource.DecimalSI),
    			},
    		},
    	}
    	nodeInfo := &schedulerframework.NodeInfo{}
    	nodeInfo.SetNode(cachedNode)
    
    	testManager.UpdatePluginResources(nodeInfo, &lifecycle.PodAdmitAttributes{Pod: pod})
    
    	allocatableScalarResources := nodeInfo.Allocatable.ScalarResources
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/cache/cache_test.go

    func buildNodeInfo(node *v1.Node, pods []*v1.Pod, imageStates map[string]*framework.ImageStateSummary) *framework.NodeInfo {
    	expected := framework.NewNodeInfo()
    	expected.SetNode(node)
    	expected.Allocatable = framework.NewResource(node.Status.Allocatable)
    	expected.Generation++
    	for _, pod := range pods {
    		expected.AddPod(pod)
    	}
    	for _, image := range node.Status.Images {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				cache.AddNode(logger, node)
    				nodes[i] = node
    
    				// Set nodeInfo to extenders to mock extenders' cache for preemption.
    				cachedNodeInfo := framework.NewNodeInfo()
    				cachedNodeInfo.SetNode(node)
    				cachedNodeInfoMap[node.Name] = cachedNodeInfo
    			}
    			var extenders []framework.Extender
    			for _, extender := range test.extenders {
    				// Set nodeInfoMap as extenders cached node information.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
Back to top