INNER CODE UNIT · Go

setupScheduler

kubernetes-sigs/kueue · cmd/kueue/main.go:661

func setupScheduler(
	mgr ctrl.Manager,
	cCache *schdcache.Cache,
	queues *qcache.Manager,
	cfg *configapi.Configuration,
	roleTracker *roletracker.RoleTracker,
	preemptionExpectations *expectations.Store,
	customLabels *metrics.CustomLabels,
	resourceFormatter *resources.ResourceFormatter,
) error {
	sched := scheduler.New(
		queues,
		cCache,
		mgr.GetClient(),
		mgr.GetEventRecorder(constants.AdmissionName),
		scheduler.WithPodsReadyRequeuingTimestamp(podsReadyRequeuingTimestamp(cfg)),
		scheduler.WithFairSharing(cfg.FairSharing),
		scheduler.WithAdmissionFairSharing(cfg.AdmissionFairSharing),

View source record →