add PriorityClassName to epp deployment

Author: friedrichwilken

pkg/eventing/deployment.go

@@ -5,14 +5,15 @@ import (
 	"strconv"
 	"strings"
 
-	"github.com/kyma-project/eventing-manager/api/v1alpha1"
-	"github.com/kyma-project/eventing-manager/pkg/env"
-	"github.com/kyma-project/eventing-manager/pkg/utils"
 	appsv1 "k8s.io/api/apps/v1"
 	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/intstr"
+
+	"github.com/kyma-project/eventing-manager/api/v1alpha1"
+	"github.com/kyma-project/eventing-manager/pkg/env"
+	"github.com/kyma-project/eventing-manager/pkg/utils"
 )
 
 const (
@@ -38,6 +39,8 @@ const (
 
 	PublisherSecretEMSURLKey       = "ems-publish-url"
 	PublisherSecretBEBNamespaceKey = "beb-namespace"
+
+	priorityClassName = "eventing-manager-priority-class"
 )
 
 var (
@@ -56,6 +59,7 @@ func newNATSPublisherDeployment(
 		WithNATSEnvVars(natsConfig, publisherConfig, eventing),
 		WithLogEnvVars(publisherConfig, eventing),
 		WithAffinity(GetPublisherDeploymentName(*eventing)),
+		WithPriorityClassName(priorityClassName),
 	)
 }
 
@@ -69,6 +73,7 @@ func newEventMeshPublisherDeployment(
 		WithContainers(publisherConfig, eventing),
 		WithBEBEnvVars(GetPublisherDeploymentName(*eventing), publisherConfig, eventing),
 		WithLogEnvVars(publisherConfig, eventing),
+		WithPriorityClassName(priorityClassName),
 	)
 }
 
@@ -135,6 +140,12 @@ func WithLabels(publisherName string, backendType v1alpha1.BackendType) DeployOp
 	}
 }
 
+func WithPriorityClassName(name string) DeployOpt {
+	return func(deployment *appsv1.Deployment) {
+		deployment.Spec.Template.Spec.PriorityClassName = name
+	}
+}
+
 func WithAffinity(publisherName string) DeployOpt {
 	return func(d *appsv1.Deployment) {
 		d.Spec.Template.Spec.Affinity = &v1.Affinity{

pkg/eventing/deployment_test.go

@@ -102,7 +102,8 @@ func Test_NewDeploymentSecurityContext(t *testing.T) {
 		testutils.WithEventingCRNamespace("test-namespace"),
 	)
 	deployment := newDeployment(givenEventing, config.PublisherConfig,
-		WithContainers(config.PublisherConfig, givenEventing))
+		WithContainers(config.PublisherConfig, givenEventing),
+	)
 
 	// when
 	podSecurityContext := deployment.Spec.Template.Spec.SecurityContext