Add schedulerName option and injection logic (#135)

Author: tardieu

internal/controller/appwrapper/resource_management.go

@@ -51,6 +51,7 @@ func parseComponent(aw *workloadv1beta2.AppWrapper, raw []byte) (*unstructured.U
 	return obj, nil
 }
 
+//gocyclo:ignore
 func (r *AppWrapperReconciler) createComponent(ctx context.Context, aw *workloadv1beta2.AppWrapper, componentIdx int) (*unstructured.Unstructured, error, bool) {
 	component := aw.Spec.Components[componentIdx]
 	toMap := func(x interface{}) map[string]string {
@@ -144,6 +145,13 @@ func (r *AppWrapperReconciler) createComponent(ctx context.Context, aw *workload
 			}
 			spec["tolerations"] = tolerations
 		}
+
+		// Scheduler Name
+		if r.Config.SchedulerName != "" {
+			if existing, _ := spec["schedulerName"].(string); existing == "" {
+				spec["schedulerName"] = r.Config.SchedulerName
+			}
+		}
 	}
 
 	if err := controllerutil.SetControllerReference(aw, obj, r.Scheme); err != nil {

pkg/config/config.go

@@ -34,6 +34,7 @@ type AppWrapperConfig struct {
 	DisableChildAdmissionCtrl  bool                  `json:"disableChildAdmissionCtrl,omitempty"`
 	UserRBACAdmissionCheck     bool                  `json:"userRBACAdmissionCheck,omitempty"`
 	FaultTolerance             *FaultToleranceConfig `json:"faultTolerance,omitempty"`
+	SchedulerName              string                `json:"schedulerName,omitempty"`
 }
 
 type FaultToleranceConfig struct {
@@ -136,7 +137,7 @@ func NewCertManagementConfig(namespace string) *CertManagementConfig {
 	}
 }
 
-// NewControllerRuntimeConfig constructs a ControllerRuntimeConfig and filles in default values
+// NewControllerRuntimeConfig constructs a ControllerRuntimeConfig and fills in default values
 func NewControllerManagerConfig() *ControllerManagerConfig {
 	return &ControllerManagerConfig{
 		Metrics: MetricsConfiguration{