Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for RunReservePluginsUnreserve (0.26 sec)

  1. pkg/scheduler/schedule_one.go

    	if sts := fwk.RunReservePluginsReserve(ctx, state, assumedPod, scheduleResult.SuggestedHost); !sts.IsSuccess() {
    		// trigger un-reserve to clean up state associated with the reserved Pod
    		fwk.RunReservePluginsUnreserve(ctx, state, assumedPod, scheduleResult.SuggestedHost)
    		if forgetErr := sched.Cache.ForgetPod(logger, assumedPod); forgetErr != nil {
    			logger.Error(forgetErr, "Scheduler cache ForgetPod failed")
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/interface.go

    	// such case, pod will not be scheduled.
    	RunReservePluginsReserve(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status
    
    	// RunReservePluginsUnreserve runs the Unreserve method of the set of
    	// configured Reserve plugins.
    	RunReservePluginsUnreserve(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string)
    
    	// RunPermitPlugins runs the set of configured Permit plugins. If any of these
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/framework.go

    	return status
    }
    
    // RunReservePluginsUnreserve runs the Unreserve method in the set of
    // configured reserve plugins.
    func (f *frameworkImpl) RunReservePluginsUnreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) {
    	startTime := time.Now()
    	defer func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/runtime/framework_test.go

    			wantExtensionPoint: "Reserve",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "Unreserve - Success",
    			action:             func(f framework.Framework) { f.RunReservePluginsUnreserve(context.Background(), state, pod, "") },
    			wantExtensionPoint: "Unreserve",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "PreBind - Success",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
Back to top