feat: add environment flag to shared options and log its value in run commands

Author: n3rdc4ptn

cmd/usage-operator/app/app.go

@@ -33,7 +33,8 @@ func NewUsageOperatorCommand(ctx context.Context) *cobra.Command {
 }
 
 type RawSharedOptions struct {
-	DryRun bool `json:"dry-run"`
+	Environment string `json:"environment"`
+	DryRun      bool   `json:"dry-run"`
 }
 
 type SharedOptions struct {
@@ -48,6 +49,7 @@ func (o *SharedOptions) AddPersistentFlags(cmd *cobra.Command) {
 	logging.InitFlags(cmd.PersistentFlags())
 	// misc
 	cmd.PersistentFlags().BoolVar(&o.DryRun, "dry-run", false, "If set, the command aborts after evaluation of the given flags.")
+	cmd.PersistentFlags().StringVar(&o.Environment, "environment", "", "Environment name. Required. This is used to distinguish between different environments that are watching the same Onboarding cluster. Must be globally unique.")
 }
 
 func (o *SharedOptions) Complete() error {

cmd/usage-operator/app/init.go

@@ -58,6 +58,7 @@ func (o *InitOptions) Complete(ctx context.Context) error {
 
 func (o *InitOptions) Run(ctx context.Context) error {
 	log := o.Log.WithName("main")
+	log.Info("Environment", "value", o.Environment)
 
 	// apply CRDs
 	crdManager := crdutil.NewCRDManager(apiconst.ClusterLabel, crds.CRDs)

cmd/usage-operator/app/run.go

@@ -239,6 +239,7 @@ func (o *RunOptions) PrintCompletedOptions(cmd *cobra.Command) {
 
 func (o *RunOptions) Run(ctx context.Context) error {
 	setupLog = o.Log.WithName("setup")
+	setupLog.Info("Environment", "value", o.Environment)
 
 	webhookServer := webhook.NewServer(webhook.Options{
 		TLSOpts: o.WebhookTLSOpts,