Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PreEnqueuePlugins (0.12 sec)

  1. pkg/scheduler/framework/runtime/framework.go

    		newPlugins := reflect.Append(plugins, reflect.ValueOf(pg))
    		plugins.Set(newPlugins)
    	}
    	return nil
    }
    
    // PreEnqueuePlugins returns the registered preEnqueue plugins.
    func (f *frameworkImpl) PreEnqueuePlugins() []framework.PreEnqueuePlugin {
    	return f.preEnqueuePlugins
    }
    
    // EnqueueExtensions returns the registered reenqueue plugins.
    func (f *frameworkImpl) EnqueueExtensions() []framework.EnqueueExtensions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue.go

    	pInfo.Gated = !p.runPreEnqueuePlugins(context.Background(), pInfo)
    	if pInfo.Gated {
    		// Add the Pod to unschedulablePods if it's not passing PreEnqueuePlugins.
    		p.unschedulablePods.addOrUpdate(pInfo)
    		return false, nil
    	}
    	if pInfo.InitialAttemptTimestamp == nil {
    		now := p.clock.Now()
    		pInfo.InitialAttemptTimestamp = &now
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top