Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 670 for FRAMEWORK (0.15 sec)

  1. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go

    	}
    	errStatus := framework.NewStatus(framework.Unschedulable, ErrReasonDiskConflict)
    	tests := []struct {
    		pod                 *v1.Pod
    		nodeInfo            *framework.NodeInfo
    		name                string
    		preFilterWantStatus *framework.Status
    		wantStatus          *framework.Status
    	}{
    		{
    			pod:                 &v1.Pod{},
    			nodeInfo:            framework.NewNodeInfo(),
    			name:                "nothing",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 17.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    		// See: https://github.com/kubernetes/kubernetes/issues/110175
    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.UpdateNodeLabel | framework.UpdateNodeTaint}},
    		// We rely on CSI node to translate in-tree PV to CSI.
    		{Event: framework.ClusterEvent{Resource: framework.CSINode, ActionType: framework.Add | framework.Update}},
    		// When CSIStorageCapacity is enabled, pods may become schedulable
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/preemption/preemption_test.go

    			nodesStatuses: framework.NodeToStatusMap{
    				"node1": framework.NewStatus(framework.UnschedulableAndUnresolvable, interpodaffinity.ErrReasonAffinityRulesNotMatch),
    				"node2": framework.NewStatus(framework.Unschedulable, interpodaffinity.ErrReasonAntiAffinityRulesNotMatch),
    				"node3": framework.NewStatus(framework.Unschedulable, "Unschedulable"),
    				"node4": framework.NewStatus(framework.Unschedulable, "Unschedulable"),
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    		// A new Node may make a pod schedulable.
    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add}},
    		// Pods may fail to schedule because the PVC it uses has not yet been created.
    		// This PVC is required to exist to check its access modes.
    		{Event: framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Add | framework.Update}},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/volumezone/volume_zone.go

    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.UpdateNodeLabel | framework.UpdateNodeTaint}},
    		// A new pvc may make a pod schedulable.
    		// Due to fields are immutable except `spec.resources`, pvc update events are ignored.
    		{Event: framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Add}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    		// We can remove UpdateNodeTaint when we remove the preCheck feature.
    		// See: https://github.com/kubernetes/kubernetes/issues/110175
    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.Delete | framework.UpdateNodeLabel | framework.UpdateNodeTaint}, QueueingHintFn: pl.isSchedulableAfterNodeChange},
    	}
    }
    
    func involvedInTopologySpreading(incomingPod, podWithSpreading *v1.Pod) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go

    					},
    				},
    			},
    			wantFilterStatus: framework.NewStatus(framework.UnschedulableAndUnresolvable, ErrReasonConflict),
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			state := framework.NewCycleState()
    			node := &framework.NodeInfo{}
    			node.SetNode(test.Node)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 05:17:04 UTC 2023
    - 20K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    func (pl *InterPodAffinity) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    	var allNodes []*framework.NodeInfo
    	var nodesWithRequiredAntiAffinityPods []*framework.NodeInfo
    	var err error
    	if allNodes, err = pl.sharedLister.NodeInfos().List(); err != nil {
    		return nil, framework.AsStatus(fmt.Errorf("failed to list NodeInfos: %w", err))
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  9. pkg/scheduler/schedule_one.go

    // Filters the nodes to find the ones that fit the pod based on the framework
    // filter plugins and filter extenders.
    func (sched *Scheduler) findNodesThatFitPod(ctx context.Context, fwk framework.Framework, state *framework.CycleState, pod *v1.Pod) ([]*framework.NodeInfo, framework.Diagnosis, error) {
    	logger := klog.FromContext(ctx)
    	diagnosis := framework.Diagnosis{
    		NodeToStatusMap: make(framework.NodeToStatusMap),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    func (pl *InterPodAffinity) PreScore(
    	pCtx context.Context,
    	cycleState *framework.CycleState,
    	pod *v1.Pod,
    	nodes []*framework.NodeInfo,
    ) *framework.Status {
    	if len(nodes) == 0 {
    		// No nodes to score.
    		return framework.NewStatus(framework.Skip)
    	}
    
    	if pl.sharedLister == nil {
    		return framework.NewStatus(framework.Error, "empty shared lister in InterPodAffinity PreScore")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
Back to top