Add configurable selinux options for datamover backup:

changelogs/unreleased/8255-sseago

@@ -0,0 +1 @@
+Add configurable selinux options for datamover backup

pkg/cmd/cli/install/install.go

@@ -36,6 +36,7 @@
 	"github.com/vmware-tanzu/velero/pkg/cmd"
 	"github.com/vmware-tanzu/velero/pkg/cmd/util/flag"
 	"github.com/vmware-tanzu/velero/pkg/cmd/util/output"
+	"github.com/vmware-tanzu/velero/pkg/exposer"
 	"github.com/vmware-tanzu/velero/pkg/install"
 	kubeutil "github.com/vmware-tanzu/velero/pkg/util/kube"
 )
@@ -89,6 +90,7 @@
 	BackupRepoConfigMap             string
 	RepoMaintenanceJobConfigMap     string
 	NodeAgentConfigMap              string
+	SELinuxDatamover                string
 }
 
 // BindFlags adds command line values to the options struct.
@@ -182,6 +184,12 @@
 		o.NodeAgentConfigMap,
 		"The name of ConfigMap containing node-agent configurations.",
 	)
+	flags.StringVar(
+		&o.SELinuxDatamover,
+		"selinux-datamover",
+		o.SELinuxDatamover,
+		"Data Mover backup pod options for handling selinux. Supported values are 'none', 'no-relabeling', and 'no-readonly'. Default is 'none'.",
+	)
 }
 
 // NewInstallOptions instantiates a new, default InstallOptions struct.
@@ -283,6 +291,7 @@
 		BackupRepoConfigMap:             o.BackupRepoConfigMap,
 		RepoMaintenanceJobConfigMap:     o.RepoMaintenanceJobConfigMap,
 		NodeAgentConfigMap:              o.NodeAgentConfigMap,
+		SELinuxDatamover:                o.SELinuxDatamover,
 	}, nil
 }
 
@@ -421,6 +430,10 @@
 		fmt.Printf("⚠️  %s\n", msg)
 	}
 
+	if err := exposer.ValidateSELinuxDatamover(o.SELinuxDatamover); err != nil {
+		return err
+	}
+
 	// If we're only installing CRDs, we can skip the rest of the validation.
 	if o.CRDsOnly {
 		return nil

pkg/cmd/cli/nodeagent/server.go

@@ -57,6 +57,7 @@
 	"github.com/vmware-tanzu/velero/pkg/constant"
 	"github.com/vmware-tanzu/velero/pkg/controller"
 	"github.com/vmware-tanzu/velero/pkg/datapath"
+	"github.com/vmware-tanzu/velero/pkg/exposer"
 	"github.com/vmware-tanzu/velero/pkg/metrics"
 	"github.com/vmware-tanzu/velero/pkg/nodeagent"
 	"github.com/vmware-tanzu/velero/pkg/repository"
@@ -89,6 +90,7 @@
 	resourceTimeout         time.Duration
 	dataMoverPrepareTimeout time.Duration
 	nodeAgentConfig         string
+	selinuxDatamover        string
 }
 
 func NewServerCommand(f client.Factory) *cobra.Command {
@@ -126,6 +128,12 @@
 	command.Flags().DurationVar(&config.dataMoverPrepareTimeout, "data-mover-prepare-timeout", config.dataMoverPrepareTimeout, "How long to wait for preparing a DataUpload/DataDownload. Default is 30 minutes.")
 	command.Flags().StringVar(&config.metricsAddress, "metrics-address", config.metricsAddress, "The address to expose prometheus metrics")
 	command.Flags().StringVar(&config.nodeAgentConfig, "node-agent-configmap", config.nodeAgentConfig, "The name of ConfigMap containing node-agent configurations.")
+	command.Flags().StringVar(
+		&config.selinuxDatamover,
+		"selinux-datamover",
+		config.selinuxDatamover,
+		"Data Mover backup pod options for handling selinux. Supported values are 'none', 'no-relabeling', and 'no-readonly'. Default is 'none'.",
+	)
 
 	return command
 }
@@ -239,6 +247,10 @@
 	s.getDataPathConfigs()
 	s.dataPathMgr = datapath.NewManager(s.getDataPathConcurrentNum(defaultDataPathConcurrentNum))
 
+	if err = exposer.ValidateSELinuxDatamover(config.selinuxDatamover); err != nil {
+		return nil, err
+	}
+
 	return s, nil
 }
 
@@ -330,6 +342,7 @@
 		s.config.dataMoverPrepareTimeout,
 		s.logger,
 		s.metrics,
+		s.config.selinuxDatamover,
 	)
 	if err = dataUploadReconciler.SetupWithManager(s.mgr); err != nil {
 		s.logger.WithError(err).Fatal("Unable to create the data upload controller")

pkg/controller/data_upload_controller.go

@@ -76,6 +76,7 @@ type DataUploadReconciler struct {
 	podResources        corev1.ResourceRequirements
 	preparingTimeout    time.Duration
 	metrics             *metrics.ServerMetrics
+	selinuxDatamover    string
 }
 
 func NewDataUploadReconciler(
@@ -92,6 +93,7 @@ func NewDataUploadReconciler(
 	preparingTimeout time.Duration,
 	log logrus.FieldLogger,
 	metrics *metrics.ServerMetrics,
+	selinuxDatamover string,
 ) *DataUploadReconciler {
 	return &DataUploadReconciler{
 		client:            client,
@@ -114,6 +116,7 @@ func NewDataUploadReconciler(
 		podResources:     podResources,
 		preparingTimeout: preparingTimeout,
 		metrics:          metrics,
+		selinuxDatamover: selinuxDatamover,
 	}
 }
 
@@ -816,6 +819,7 @@ func (r *DataUploadReconciler) setupExposeParam(du *velerov2alpha1api.DataUpload
 			Affinity:         r.loadAffinity,
 			BackupPVCConfig:  r.backupPVCConfig,
 			Resources:        r.podResources,
+			SELinuxDatamover: r.selinuxDatamover,
 		}, nil
 	}
 	return nil, nil

pkg/controller/data_upload_controller_test.go

@@ -245,6 +245,7 @@ func initDataUploaderReconcilerWithError(needError ...error) (*DataUploadReconci
 		time.Minute*5,
 		velerotest.NewLogger(),
 		metrics.NewServerMetrics(),
+		"",
 	), nil
 }
 

pkg/exposer/csi_snapshot.go

@@ -73,6 +73,12 @@
 
 	// Resources defines the resource requirements of the hosting pod
 	Resources corev1.ResourceRequirements
+
+	// SELinuxDatamover defines how to modify pod definition for SELinux
+	// none: no changes (won't work in SELinux environments). Default value if field is empty.
+	// no-relabeling: Sets securityContext.SELinuxOptions.Type=spc_t. Preferred configuration for SELinux with some performance improvements for volumes with many files, but won't work with restricted pods.
+	// no-readonly: Removes volumes.volumeSource.PVC.ReadOnly=true. For SELinux environments where spc_t is not allowed, but may break shallow copy.
+	SELinuxDatamover string
 }
 
 // CSISnapshotExposeWaitParam define the input param for WaitExposed of CSI snapshots
@@ -202,6 +208,7 @@
 		csiExposeParam.HostingPodLabels,
 		csiExposeParam.Affinity,
 		csiExposeParam.Resources,
+		csiExposeParam.SELinuxDatamover,
 	)
 	if err != nil {
 		return errors.Wrap(err, "error to create backup pod")
@@ -441,6 +448,7 @@
 	label map[string]string,
 	affinity *kube.LoadAffinity,
 	resources corev1.ResourceRequirements,
+	selinuxDatamover string,
 ) (*corev1.Pod, error) {
 	podName := ownerObject.Name
 
@@ -461,10 +469,14 @@
 		VolumeSource: corev1.VolumeSource{
 			PersistentVolumeClaim: &corev1.PersistentVolumeClaimVolumeSource{
 				ClaimName: backupPVC.Name,
-				ReadOnly:  true,
 			},
 		},
 	}}
+
+	if selinuxDatamover != SELinuxNoReadOnly {
+		volumes[0].VolumeSource.PersistentVolumeClaim.ReadOnly = true
+	}
+
 	volumes = append(volumes, podInfo.volumes...)
 
 	if label == nil {
@@ -550,5 +562,11 @@
 		},
 	}
 
+	if selinuxDatamover == SELinuxNoRelabeling {
+		pod.Spec.SecurityContext.SELinuxOptions = &corev1.SELinuxOptions{
+			Type: "spc_t",
+		}
+	}
+
 	return e.kubeClient.CoreV1().Pods(ownerObject.Namespace).Create(ctx, pod, metav1.CreateOptions{})
 }

pkg/exposer/types.go

@@ -17,6 +17,9 @@
 package exposer
 
 import (
+	"fmt"
+	"strings"
+
 	corev1 "k8s.io/api/core/v1"
 )
 
@@ -25,6 +28,9 @@
 	AccessModeBlock      = "by-block-device"
 	podGroupLabel        = "velero.io/exposer-pod-group"
 	podGroupSnapshot     = "snapshot-exposer"
+	SELinuxNone          = "none"
+	SELinuxNoRelabeling  = "no-relabeling"
+	SELinuxNoReadOnly    = "no-readonly"
 )
 
 // ExposeResult defines the result of expose.
@@ -39,3 +45,14 @@
 	HostingContainer string
 	VolumeName       string
 }
+
+// ValidateSelinuxDatamover validates if the input param is a valid SELinux approach for data mover.
+// It will return an error if it's invalid.
+func ValidateSELinuxDatamover(t string) error {
+	t = strings.TrimSpace(t)
+	if t != "" && t != SELinuxNone && t != SELinuxNoRelabeling && t != SELinuxNoReadOnly {
+		return fmt.Errorf("invalid SELinux datamover option '%s', valid options are: '%s', '%s', '%s'", t, SELinuxNone, SELinuxNoRelabeling, SELinuxNoReadOnly)
+	}
+
+	return nil
+}

pkg/install/daemonset.go

@@ -54,6 +54,10 @@ func DaemonSet(namespace string, opts ...podTemplateOption) *appsv1.DaemonSet {
 		daemonSetArgs = append(daemonSetArgs, fmt.Sprintf("--node-agent-configmap=%s", c.nodeAgentConfigMap))
 	}
 
+	if len(c.selinuxDatamover) > 0 {
+		daemonSetArgs = append(daemonSetArgs, fmt.Sprintf("--selinux-datamover=%s", c.selinuxDatamover))
+	}
+
 	userID := int64(0)
 	mountPropagationMode := corev1.MountPropagationHostToContainer
 

pkg/install/deployment.go

@@ -57,6 +57,7 @@
 	backupRepoConfigMap             string
 	repoMaintenanceJobConfigMap     string
 	nodeAgentConfigMap              string
+	selinuxDatamover                string
 }
 
 func WithImage(image string) podTemplateOption {
@@ -183,6 +184,12 @@
 	}
 }
 
+func WithSELinuxDatamover(selinuxDatamover string) podTemplateOption {
+	return func(c *podTemplateConfig) {
+		c.selinuxDatamover = selinuxDatamover
+	}
+}
+
 func WithScheduleSkipImmediately(b bool) podTemplateOption {
 	return func(c *podTemplateConfig) {
 		c.scheduleSkipImmediately = b

pkg/install/resources.go

@@ -267,6 +267,7 @@
 	BackupRepoConfigMap             string
 	RepoMaintenanceJobConfigMap     string
 	NodeAgentConfigMap              string
+	SELinuxDatamover                string
 }
 
 func AllCRDs() *unstructured.UnstructuredList {
@@ -411,6 +412,9 @@
 		if len(o.NodeAgentConfigMap) > 0 {
 			dsOpts = append(dsOpts, WithNodeAgentConfigMap(o.NodeAgentConfigMap))
 		}
+		if len(o.SELinuxDatamover) > 0 {
+			dsOpts = append(dsOpts, WithSELinuxDatamover(o.SELinuxDatamover))
+		}
 
 		ds := DaemonSet(o.Namespace, dsOpts...)
 		if err := appendUnstructured(resources, ds); err != nil {