INNER CODE UNIT · Go
setupControllers
kubernetes-sigs/kueue · cmd/kueue/main.go:497
func setupControllers(
ctx context.Context,
mgr ctrl.Manager,
cCache *schdcache.Cache,
queues *qcache.Manager,
cfg *configapi.Configuration,
serverVersionFetcher *kubeversion.ServerVersionFetcher,
integrationManager *jobframework.IntegrationManager,
opts core.SetupControllersOpts,
) error {
if failedCtrl, err := core.SetupControllers(mgr, queues, cCache, cfg, opts); err != nil {
return fmt.Errorf("unable to create controller %s: %w", failedCtrl, err)
}
if features.Enabled(features.FailureRecoveryPolicy) {
if failedCtrlName, err := failurerecovery.SetupControllers(mgr, cfg, opts.RoleTracker); err != nil {
return fmt.Errorf("could not setup FailureRecovery controller %s: %w", failedCtrlName, err)
}
}