Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for RunBindPlugins (0.18 sec)

  1. pkg/scheduler/framework/interface.go

    	// RunBindPlugins runs the set of configured Bind plugins. A Bind plugin may choose
    	// whether or not to handle the given Pod. If a Bind plugin chooses to skip the
    	// binding, it should return code=5("skip") status. Otherwise, it should return "Error"
    	// or "Success". If none of the plugins handled binding, RunBindPlugins returns
    	// code=5("skip") status.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/runtime/framework_test.go

    			wantExtensionPoint: "PreBind",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "Bind - Success",
    			action:             func(f framework.Framework) { f.RunBindPlugins(context.Background(), state, pod, "") },
    			wantExtensionPoint: "Bind",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "PostBind - Success",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/framework.go

    	f.metricsRecorder.ObservePluginDurationAsync(metrics.PreBind, pl.Name(), status.Code().String(), metrics.SinceInSeconds(startTime))
    	return status
    }
    
    // RunBindPlugins runs the set of configured bind plugins until one returns a non `Skip` status.
    func (f *frameworkImpl) RunBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status) {
    	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/schedule_one.go

    		sched.finishBinding(logger, fwk, assumed, targetNode, status)
    	}()
    
    	bound, err := sched.extendersBinding(logger, assumed, targetNode)
    	if bound {
    		return framework.AsStatus(err)
    	}
    	return fwk.RunBindPlugins(ctx, state, assumed, targetNode)
    }
    
    // TODO(#87159): Move this to a Plugin.
    func (sched *Scheduler) extendersBinding(logger klog.Logger, pod *v1.Pod, node string) (bool, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
Back to top