Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PreEnqueuePlugins (0.15 sec)

  1. pkg/scheduler/scheduler.go

    	queueingHintsPerProfile := make(internalqueue.QueueingHintMapPerProfile)
    	for profileName, profile := range profiles {
    		preEnqueuePluginMap[profileName] = profile.PreEnqueuePlugins()
    		queueingHintsPerProfile[profileName] = buildQueueingHintMap(profile.EnqueueExtensions())
    	}
    
    	podQueue := internalqueue.NewSchedulingQueue(
    		profiles[options.profiles[0].SchedulerName].QueueSortFunc(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/types.go

    	UnschedulablePlugins sets.Set[string]
    	// PendingPlugins records the plugin names that the Pod failed with Pending status.
    	PendingPlugins sets.Set[string]
    	// Whether the Pod is scheduling gated (by PreEnqueuePlugins) or not.
    	Gated bool
    }
    
    // DeepCopy returns a deep copy of the QueuedPodInfo object.
    func (pqi *QueuedPodInfo) DeepCopy() *QueuedPodInfo {
    	return &QueuedPodInfo{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  3. 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