Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for isSchedulableAfterPodChange (1.51 sec)

  1. pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go

    	}
    }
    
    // New initializes a new plugin and returns it.
    func New(_ context.Context, _ runtime.Object, _ framework.Handle, fts feature.Features) (framework.Plugin, error) {
    	return &SchedulingGates{
    		enableSchedulingQueueHint: fts.EnableSchedulingQueueHint,
    	}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go

    	}, nil
    }
    
    // isSchedulableAfterPodChange is invoked whenever a pod changed. It checks whether
    // that change made a previously unschedulable pod schedulable.
    // When an unscheduled Pod, which was rejected by TaintToleration, is updated to have a new toleration,
    // it may make the Pod schedulable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go

    			logger, ctx := ktesting.NewTestContext(t)
    			p, err := New(ctx, nil, nil, feature.Features{})
    			if err != nil {
    				t.Fatalf("Creating plugin: %v", err)
    			}
    			actualHint, err := p.(*SchedulingGates).isSchedulableAfterPodChange(logger, tc.pod, tc.oldObj, tc.newObj)
    			if tc.expectedErr {
    				require.Error(t, err)
    				return
    			}
    			require.NoError(t, err)
    			require.Equal(t, tc.expectedHint, actualHint)
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/fit.go

    		{Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: podActionType}, QueueingHintFn: f.isSchedulableAfterPodChange},
    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.Update}, QueueingHintFn: f.isSchedulableAfterNodeChange},
    	}
    }
    
    // isSchedulableAfterPodChange is invoked whenever a pod deleted or updated. It checks whether
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    		// See: https://github.com/kubernetes/kubernetes/issues/110175
    		{Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.All}, QueueingHintFn: pl.isSchedulableAfterPodChange},
    		{Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.UpdateNodeLabel | framework.UpdateNodeTaint}, QueueingHintFn: pl.isSchedulableAfterNodeChange},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    		// deleting an existing Pod may make it schedulable.
    		{Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.All}, QueueingHintFn: pl.isSchedulableAfterPodChange},
    		// Node add|delete|update maybe lead an topology key changed,
    		// and make these pod in scheduling schedulable or unschedulable.
    		//
    		// A note about UpdateNodeTaint event:
    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/interpodaffinity/plugin_test.go

    			snapshot := cache.NewSnapshot(nil, nil)
    			pl := plugintesting.SetupPluginWithInformers(ctx, t, New, &config.InterPodAffinityArgs{}, snapshot, namespaces)
    			p := pl.(*InterPodAffinity)
    			actualHint, err := p.isSchedulableAfterPodChange(logger, tc.pod, tc.oldPod, tc.newPod)
    			if err != nil {
    				t.Errorf("unexpected error: %v", err)
    			}
    			if diff := cmp.Diff(tc.expectedHint, actualHint); diff != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/podtopologyspread/plugin_test.go

    			pl := plugintesting.SetupPlugin(ctx, t, topologySpreadFunc, &config.PodTopologySpreadArgs{DefaultingType: config.ListDefaulting}, snapshot)
    			p := pl.(*PodTopologySpread)
    			actualHint, err := p.isSchedulableAfterPodChange(logger, tc.pod, tc.oldPod, tc.newPod)
    			if tc.expectedErr {
    				require.Error(t, err)
    				return
    			}
    			require.NoError(t, err)
    			require.Equal(t, tc.expectedHint, actualHint)
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 17 06:30:53 UTC 2023
    - 13K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    			logger, ctx := ktesting.NewTestContext(t)
    			p, err := New(ctx, nil, nil, feature.Features{})
    			if err != nil {
    				t.Fatalf("creating plugin: %v", err)
    			}
    			actualHint, err := p.(*TaintToleration).isSchedulableAfterPodChange(logger, tc.pod, tc.oldObj, tc.newObj)
    			if tc.expectedErr {
    				if err == nil {
    					t.Errorf("unexpected success")
    				}
    				return
    			}
    			if err != nil {
    				t.Errorf("unexpected error")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    				EnableInPlacePodVerticalScaling: tc.enableInPlacePodVerticalScaling,
    			})
    			if err != nil {
    				t.Fatal(err)
    			}
    			actualHint, err := p.(*Fit).isSchedulableAfterPodChange(logger, tc.pod, tc.oldObj, tc.newObj)
    			if tc.expectedErr {
    				require.Error(t, err)
    				return
    			}
    			require.NoError(t, err)
    			require.Equal(t, tc.expectedHint, actualHint)
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
Back to top