Integrated Salt event processor into mgradm install workflow

- Created service flag structure and implemented flag registration
- Added container setup in mgradm install
- Registered service

Author: Symorglass

mgradm/cmd/install/flags.go

@@ -29,6 +29,8 @@ func AddInstallFlags(cmd *cobra.Command) {
 	_ = utils.AddFlagHelpGroup(cmd, &utils.Group{ID: "tftpd-container", Title: L("TFTPD Flags")})
 	utils.AddTFTPDFlags(cmd, true, "tftpd-container")
 
+	cmd_utils.AddEventProcessorFlag(cmd, false)
+
 	cmd.Flags().String("admin-login", "admin", L("Administrator user name"))
 	cmd.Flags().String("admin-password", "", L("Administrator password"))
 	cmd.Flags().String("admin-firstName", "Administrator", L("First name of the administrator"))

mgradm/cmd/install/install.go

@@ -60,6 +60,7 @@ func getFlagsUpdater(flags *podmanInstallFlags) utils.FlagsUpdaterFunc {
 	return func(v *viper.Viper) {
 		flags.Coco.IsChanged = v.IsSet("coco.replicas")
 		flags.HubXmlrpc.IsChanged = v.IsSet("hubxmlrpc.replicas")
+		flags.EventProcessor.IsChanged = v.IsSet("eventprocessor.replicas")
 		flags.Saline.IsChanged = v.IsSet("saline.replicas") || v.IsSet("saline.port")
 		flags.TFTPD.IsChanged = v.IsSet("tftpd.enable")
 

mgradm/cmd/install/utils.go

@@ -13,6 +13,7 @@ import (
 	"github.com/spf13/cobra"
 	"github.com/uyuni-project/uyuni-tools/mgradm/cmd/backup/db"
 	"github.com/uyuni-project/uyuni-tools/mgradm/shared/coco"
+	"github.com/uyuni-project/uyuni-tools/mgradm/shared/eventprocessor"
 	"github.com/uyuni-project/uyuni-tools/mgradm/shared/hub"
 	"github.com/uyuni-project/uyuni-tools/mgradm/shared/pgsql"
 	"github.com/uyuni-project/uyuni-tools/mgradm/shared/podman"
@@ -115,6 +116,10 @@ func installForPodman(
 		hub.SetupHubXmlrpc(systemd, authFile, flags.Image, flags.HubXmlrpc),
 		saline.SetupSalineContainer(systemd, authFile, flags.Image, flags.Saline, flags.Installation.TZ),
 		tftp.SetupTFTPContainer(systemd, authFile, flags.Image, flags.TFTPD, fqdn, false),
+		eventprocessor.SetupEventProcessorContainer(
+			systemd, authFile, flags.Image, flags.EventProcessor, flags.Installation.DB,
+			flags.Installation.Debug.Java,
+		),
 	)
 }
 
@@ -157,5 +162,6 @@ func setupDatabase(dbFlags types.DBFlags, reportdbFlags types.DBFlags, preparedI
 			return err
 		}
 	}
+
 	return nil
 }

mgradm/cmd/restart/podman.go

@@ -1,4 +1,4 @@
-// SPDX-FileCopyrightText: 2025 SUSE LLC
+// SPDX-FileCopyrightText: 2026 SUSE LLC
 //
 // SPDX-License-Identifier: Apache-2.0
 
@@ -24,5 +24,6 @@ func podmanRestart(
 		systemd.RestartService(podman.ServerService),
 		systemd.RestartInstantiated(podman.ServerAttestationService),
 		systemd.RestartInstantiated(podman.HubXmlrpcService),
+		systemd.RestartInstantiated(podman.EventProcessorService),
 	)
 }

mgradm/cmd/status/podman.go

@@ -51,6 +51,13 @@ func podmanStatus(
 		)
 	}
 
+	for i := 0; i < systemd.CurrentReplicaCount(podman.EventProcessorService); i++ {
+		println() // add an empty line between the previous logs and this one
+		_ = utils.RunCmdStdMapping(
+			zerolog.DebugLevel, "systemctl", "status", "--no-pager", fmt.Sprintf("%s@%d", podman.EventProcessorService, i),
+		)
+	}
+
 	if systemd.HasService(podman.TFTPService) {
 		_ = utils.RunCmdStdMapping(zerolog.DebugLevel, "systemctl", "status", "--no-pager", podman.TFTPService)
 	}

mgradm/cmd/support/ptf/utils.go

@@ -58,6 +58,7 @@ func ptfForPodman(
 		flags.Coco,
 		flags.HubXmlrpc,
 		flags.Saline,
+		flags.EventProcessor,
 		flags.Pgsql,
 		flags.TFTPD,
 		flags.Installation.TZ,

mgradm/cmd/uninstall/podman.go

@@ -26,6 +26,7 @@ func uninstallForPodman(
 		podman.GetServiceImage(podman.ServerService),
 		podman.GetServiceImage(podman.ServerAttestationService + "@"),
 		podman.GetServiceImage(podman.HubXmlrpcService + "@"),
+		podman.GetServiceImage(podman.EventProcessorService + "@"),
 		podman.GetServiceImage(podman.SalineService + "@"),
 		podman.GetServiceImage(podman.DBService),
 		podman.GetServiceImage(podman.TFTPService),
@@ -35,9 +36,9 @@ func uninstallForPodman(
 	systemd.UninstallService("uyuni-server", !flags.Force)
 	// Force stop the pod
 	podman.DeleteContainer(podman.ServerContainerName, !flags.Force)
-
 	systemd.UninstallInstantiatedService(podman.ServerAttestationService, !flags.Force)
 	systemd.UninstallInstantiatedService(podman.HubXmlrpcService, !flags.Force)
+	systemd.UninstallInstantiatedService(podman.EventProcessorService, !flags.Force)
 	systemd.UninstallInstantiatedService(podman.SalineService, !flags.Force)
 	systemd.UninstallService(podman.DBService, !flags.Force)
 	systemd.UninstallService(podman.TFTPService, !flags.Force)

mgradm/cmd/upgrade/flags.go

@@ -18,6 +18,7 @@ func AddUpgradeFlags(cmd *cobra.Command) {
 	adm_utils.AddDBUpgradeImageFlag(cmd)
 	adm_utils.AddUpgradeCocoFlag(cmd)
 	adm_utils.AddUpgradeHubXmlrpcFlags(cmd)
+	adm_utils.AddEventProcessorFlag(cmd, true)
 	adm_utils.AddUpgradeSalineFlag(cmd)
 	_ = utils.AddFlagHelpGroup(cmd, &utils.Group{ID: "tftpd-container", Title: L("TFTPD Flags")})
 	utils.AddTFTPDFlags(cmd, true, "tftpd-container")

mgradm/cmd/upgrade/upgrade.go

@@ -35,6 +35,7 @@ func newCmd(globalFlags *types.GlobalFlags, run utils.CommandFunc[podmanUpgradeF
 			flagsUpdater := func(v *viper.Viper) {
 				flags.Coco.IsChanged = v.IsSet("coco.replicas")
 				flags.HubXmlrpc.IsChanged = v.IsSet("hubxmlrpc.replicas")
+				flags.EventProcessor.IsChanged = v.IsSet("eventprocessor.replicas")
 				flags.Saline.IsChanged = v.IsSet("saline.replicas") || v.IsSet("saline.port")
 				flags.TFTPD.IsChanged = v.IsSet("tftpd.enable")
 			}

mgradm/cmd/upgrade/utils.go

@@ -44,6 +44,7 @@ func upgradePodman(_ *types.GlobalFlags, flags *podmanUpgradeFlags, cmd *cobra.C
 		flags.Coco,
 		flags.HubXmlrpc,
 		flags.Saline,
+		flags.EventProcessor,
 		flags.Pgsql,
 		flags.TFTPD,
 		flags.Installation.TZ,