Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PreEnqueuePlugins (0.27 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/framework/interface.go

    // Configured plugins are called at specified points in a scheduling context.
    type Framework interface {
    	Handle
    
    	// PreEnqueuePlugins returns the registered preEnqueue plugins.
    	PreEnqueuePlugins() []PreEnqueuePlugin
    
    	// EnqueueExtensions returns the registered Enqueue extensions.
    	EnqueueExtensions() []EnqueueExtensions
    
    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/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)
  4. 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)
  5. pkg/scheduler/framework/runtime/framework_test.go

    			f, err := newFrameworkWithQueueSortAndBind(ctx, registry, profile)
    			if err != nil {
    				t.Fatalf("fail to create framework: %s", err)
    			}
    
    			got := f.PreEnqueuePlugins()
    			if !reflect.DeepEqual(got, tt.want) {
    				t.Errorf("PreEnqueuePlugins(): want %v, but got %v", tt.want, got)
    			}
    		})
    	}
    }
    
    func TestRunPreScorePlugins(t *testing.T) {
    	tests := []struct {
    		name               string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  6. 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