Added support for resources request in staging jobs

internal/api/v1/application/stage.go

@@ -49,6 +49,8 @@
 	DownloadImage       string
 	UnpackImage         string
 	ServiceAccountName  string
+	CPURequest          string
+	MemoryRequest       string
 	Environment         models.EnvVariableList
 	Owner               metav1.OwnerReference
 	RegistryURL         string
@@ -220,13 +222,17 @@
 	}
 
 	serviceAccountName := viper.GetString("staging-service-account-name")
+	cpuRequest := viper.GetString("staging-resource-cpu")
+	memoryRequest := viper.GetString("staging-resource-memory")
 
 	params := stageParam{
 		AppRef:              req.App,
 		BuilderImage:        builderImage,
 		DownloadImage:       downloadImage,
 		UnpackImage:         unpackImage,
 		ServiceAccountName:  serviceAccountName,
+		CPURequest:          cpuRequest,
+		MemoryRequest:       memoryRequest,
 		BlobUID:             blobUID,
 		Environment:         environment.List(),
 		Owner:               owner,
@@ -365,7 +371,6 @@
 	previous.Stage = models.NewStage(app.PreviousStageID)
 
 	// TODO: Simplify env setup -- https://github.com/epinio/epinio/issues/1176
-
 	// Note: `source` is required because the mounted files are not executable.
 
 	// runtime: AWSCLIImage
@@ -385,7 +390,6 @@
 		protocol = "https"
 	}
 	stageEnv = appendEnvVar(stageEnv, "PROTOCOL", protocol)
-
 	stageEnv = appendEnvVar(stageEnv, "ENDPOINT", app.S3ConnectionDetails.Endpoint)
 	stageEnv = appendEnvVar(stageEnv, "BUCKET", app.S3ConnectionDetails.Bucket)
 	stageEnv = appendEnvVar(stageEnv, "BLOBID", app.BlobUID)
@@ -606,9 +610,36 @@
 		},
 	}
 
+	addResourceRequests(job, app)
 	return job, jobenv
 }
 
+func addResourceRequests(job *batchv1.Job, app stageParam) {
+	cpu := app.CPURequest
+	memory := app.MemoryRequest
+
+	if cpu == "" && memory == "" {
+		return
+	}
+
+	rr := corev1.ResourceRequirements{
+		Requests: corev1.ResourceList{},
+	}
+
+	// NOTE: Using `MustParse` is ok here, despite panicking on bad values.  The server startup
+	// code (See internal.cli/server.go, CmdServer.RunE) already verified that any non-empty
+	// values are valid. Invalid values cause the server to not start.
+
+	if cpu != "" {
+		rr.Requests[corev1.ResourceCPU] = resource.MustParse(cpu)
+	}
+	if memory != "" {
+		rr.Requests[corev1.ResourceMemory] = resource.MustParse(memory)
+	}
+
+	job.Spec.Template.Spec.Containers[0].Resources = rr
+}
+
 func getRegistryURL(ctx context.Context, cluster *kubernetes.Cluster) (string, error) {
 	cd, err := registry.GetConnectionDetails(ctx, cluster, helmchart.Namespace(), registry.CredentialsSecretName)
 	if err != nil {

internal/cli/server.go

@@ -30,6 +30,8 @@
 	"github.com/epinio/epinio/internal/upgraderesponder"
 	"github.com/epinio/epinio/internal/version"
 	"github.com/gin-gonic/gin"
+
+	"k8s.io/apimachinery/pkg/api/resource"
 	"k8s.io/client-go/rest"
 
 	"github.com/pkg/errors"
@@ -106,6 +108,18 @@
 	err = viper.BindEnv("staging-service-account-name", "STAGING_SERVICE_ACCOUNT_NAME")
 	checkErr(err)
 
+	flags.String("staging-resource-cpu", "", "(STAGING_RESOURCE_CPU)")
+	err = viper.BindPFlag("staging-resource-cpu", flags.Lookup("staging-resource-cpu"))
+	checkErr(err)
+	err = viper.BindEnv("staging-resource-cpu", "STAGING_RESOURCE_CPU")
+	checkErr(err)
+
+	flags.String("staging-resource-memory", "", "(STAGING_RESOURCE_MEMORY)")
+	err = viper.BindPFlag("staging-resource-memory", flags.Lookup("staging-resource-memory"))
+	checkErr(err)
+	err = viper.BindEnv("staging-resource-memory", "STAGING_RESOURCE_MEMORY")
+	checkErr(err)
+
 	flags.String("upgrade-responder-address", upgraderesponder.UpgradeResponderAddress, "(UPGRADE_RESPONDER_ADDRESS) Disable tracking of the running Epinio and Kubernetes versions")
 	err = viper.BindPFlag("upgrade-responder-address", flags.Lookup("upgrade-responder-address"))
 	checkErr(err)
@@ -139,6 +153,23 @@
 		cmd.SilenceUsage = true
 		logger := tracelog.NewLogger().WithName("EpinioServer")
 
+		// Validate resource requests for staging job here, on server startup, to reject bad values immediately.
+
+		cpuRequest := viper.GetString("staging-resource-cpu")
+		if cpuRequest != "" {
+			_, err := resource.ParseQuantity(cpuRequest)
+			if err != nil {
+				return errors.Wrap(err, "bad cpu request for staging job")
+			}
+		}
+		memoryRequest := viper.GetString("staging-resource-memory")
+		if memoryRequest != "" {
+			_, err := resource.ParseQuantity(memoryRequest)
+			if err != nil {
+				return errors.Wrap(err, "bad memory request for staging job")
+			}
+		}
+
 		handler, err := server.NewHandler(logger)
 		if err != nil {
 			return errors.Wrap(err, "error creating handler")