LOG-3287: replace priorty class with system-node-critical

config/default/kustomization.yaml

@@ -16,7 +16,7 @@ bases:
 - ../crd
 - ../rbac
 - ../manager
-- ../scheduling
+#- ../scheduling
 # [WEBHOOK] To enable webhook, uncomment all the sections with [WEBHOOK] prefix including the one in 
 # crd/kustomization.yaml
 #- ../webhook

internal/collector/collector.go

@@ -18,7 +18,7 @@ import (
 )
 
 const (
-	clusterLoggingPriorityClassName = "cluster-logging"
+	clusterLoggingPriorityClassName = "system-node-critical"
 	exporterPort                    = int32(2112)
 	exporterPortName                = "logfile-metrics"
 	metricsPort                     = int32(24231)

internal/runtime/priorityclass.go

@@ -0,0 +1,16 @@
+package runtime
+
+import (
+	scheduling "k8s.io/api/scheduling/v1"
+)
+
+//NewPriorityClass is a constructor to create a PriorityClass
+func NewPriorityClass(name string, priorityValue int32, globalDefault bool, description string) *scheduling.PriorityClass {
+	pc := &scheduling.PriorityClass{
+		Value:         priorityValue,
+		GlobalDefault: globalDefault,
+		Description:   description,
+	}
+	Initialize(pc, "", name)
+	return pc
+}

main.go

@@ -1,10 +1,13 @@
 package main
 
 import (
+	"context"
 	"flag"
 	"fmt"
+	"k8s.io/apimachinery/pkg/api/errors"
 	"os"
 	"runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	loggingv1 "github.com/openshift/cluster-logging-operator/apis/logging/v1"
 	ctrl "sigs.k8s.io/controller-runtime"
@@ -31,6 +34,7 @@ import (
 	securityv1 "github.com/openshift/api/security/v1"
 	"github.com/openshift/cluster-logging-operator/controllers/clusterlogging"
 	"github.com/openshift/cluster-logging-operator/controllers/forwarding"
+	loggingruntime "github.com/openshift/cluster-logging-operator/internal/runtime"
 	"github.com/openshift/cluster-logging-operator/internal/telemetry"
 	elasticsearch "github.com/openshift/elasticsearch-operator/apis/logging/v1"
 )
@@ -103,6 +107,8 @@ func main() {
 		os.Exit(1)
 	}
 
+	migrateManifestResources(mgr.GetClient())
+
 	log.Info("Registering Components.")
 
 	if err = (&clusterlogging.ReconcileClusterLogging{
@@ -157,6 +163,13 @@ func main() {
 
 }
 
+func migrateManifestResources(k8sClient client.Client) {
+	log.Info("migrating resources provided by the manifest")
+	if err := k8sClient.Delete(context.TODO(), loggingruntime.NewPriorityClass("cluster-logging", 0, false, "")); err != nil && !errors.IsNotFound(err) {
+		log.V(1).Error(err, "There was an error trying to remove the old collector PriorityClass named 'cluster-logging'")
+	}
+}
+
 // getWatchNamespace get the namespace name of the scoped operator
 // - https://sdk.operatorframework.io/docs/building-operators/golang/operator-scope/#configuring-namespace-scoped-operators
 func getWatchNamespace() (string, error) {