[Feature] Simplify Operator ID

Author: ajanikow

CHANGELOG.md

@@ -7,6 +7,7 @@
 - (Bugfix) (DP) Propagate Timeout Across Subcommands
 - (Maintenance) Bump Dependencies
 - (Feature) (Platform) EventsV1 Integration
+- (Feature) Simplify Operator ID Process
 
 ## [1.3.1](https://github.com/arangodb/kube-arangodb/tree/1.3.1) (2025-10-07)
 - (Documentation) Add ArangoPlatformStorage Docs & Examples

README.md

@@ -196,7 +196,6 @@ Flags:
       --http1.transport.keep-alive-timeout-short duration      Interval between keep-alive probes for an active network connection (default 100ms)
       --http1.transport.max-idle-conns int                     Maximum number of idle (keep-alive) connections across all hosts. Zero means no limit (default 100)
       --http1.transport.tls-handshake-timeout duration         Maximum amount of time to wait for a TLS handshake. Zero means no timeout (default 10s)
-      --image.discovery.status                                 Discover Operator Image from Pod Status by default. When disabled Pod Spec is used. (default true)
       --image.discovery.timeout duration                       Timeout for image discovery process (default 1m0s)
       --internal.scaling-integration                           Enable Scaling Integration
       --kubernetes.burst int                                   Burst for the k8s API (default 256)

cmd/cmd.go

@@ -162,7 +162,8 @@ var (
 		podSchedulingGracePeriod    time.Duration
 	}
 	operatorImageDiscovery struct {
-		timeout                time.Duration
+		timeout time.Duration
+		//deprecated: Do not use this flag, as discovery methog changed
 		defaultStatusDiscovery bool
 	}
 	operatorReconciliationRetry struct {
@@ -191,6 +192,12 @@ var (
 )
 
 func init() {
+	if err := initE(); err != nil {
+		panic(err.Error())
+	}
+}
+
+func initE() error {
 	var deprecatedStr string
 
 	f := cmdMain.Flags()
@@ -217,20 +224,14 @@ func init() {
 	f.BoolVar(&operatorOptions.enablePlatform, "operator.platform", false, "Enable to run the Platform operator")
 	f.BoolVar(&operatorOptions.enableScheduler, "operator.scheduler", false, "Enable to run the Scheduler operator")
 	f.BoolVar(&operatorOptions.enableK2KClusterSync, "operator.k2k-cluster-sync", false, "Enable to run the ListSimple operator")
-	f.MarkDeprecated("operator.k2k-cluster-sync", "Enabled within deployment operator")
 	f.BoolVar(&operatorOptions.versionOnly, "operator.version", false, "Enable only version endpoint in Operator")
 	f.StringVar(&deprecatedStr, "operator.alpine-image", "alpine:3.7", "Docker image used for alpine containers")
-	f.MarkDeprecated("operator.alpine-image", "Value is not used anymore")
 	f.StringVar(&deprecatedStr, "operator.metrics-exporter-image", "arangodb/arangodb-exporter:0.1.6", "Docker image used for metrics containers by default")
-	f.MarkDeprecated("operator.metrics-exporter-image", "Value is not used anymore")
 	f.StringVar(&deprecatedStr, "operator.arango-image", "arangodb/arangodb:latest", "Docker image used for arango by default")
-	f.MarkDeprecated("operator.arango-image", "Value is not used anymore")
 	f.BoolVar(&chaosOptions.allowed, "chaos.allowed", false, "Set to allow chaos in deployments. Only activated when allowed and enabled in deployment")
 	f.BoolVar(&operatorOptions.skipLeaderLabel, "leader.label.skip", false, "Skips Leader Label for the Pod")
 	f.BoolVar(&operatorOptions.singleMode, "mode.single", false, "Enable single mode in Operator. WARNING: There should be only one replica of Operator, otherwise Operator can take unexpected actions")
 	f.String("scope", "", "Define scope on which Operator works. Legacy - pre 1.1.0 scope with limited cluster access")
-	f.MarkDeprecated("scope", "Value is not used anymore")
-	f.MarkHidden("scope")
 	f.DurationVar(&operatorTimeouts.k8s, "timeout.k8s", globals.DefaultKubernetesTimeout, "The request timeout to the kubernetes")
 	f.DurationVar(&operatorTimeouts.arangoD, "timeout.arangod", globals.DefaultArangoDTimeout, "The request timeout to the ArangoDB")
 	f.DurationVar(&operatorTimeouts.arangoDCheck, "timeout.arangod-check", globals.DefaultArangoDCheckTimeout, "The version check request timeout to the ArangoDB")
@@ -260,21 +261,35 @@ func init() {
 	f.BoolVar(&operatorImageDiscovery.defaultStatusDiscovery, "image.discovery.status", true, "Discover Operator Image from Pod Status by default. When disabled Pod Spec is used.")
 	f.DurationVar(&operatorImageDiscovery.timeout, "image.discovery.timeout", time.Minute, "Timeout for image discovery process")
 	f.IntVar(&threads, "threads", 16, "Number of the worker threads")
-	if err := logging.Init(&cmdMain); err != nil {
-		panic(err.Error())
-	}
-	if err := features.Init(&cmdMain); err != nil {
-		panic(err.Error())
-	}
-	if err := agencyConfig.Init(&cmdMain); err != nil {
-		panic(err.Error())
+
+	if err := errors.Errors(
+		f.MarkDeprecated("operator.k2k-cluster-sync", "Enabled within deployment operator"),
+		f.MarkDeprecated("operator.alpine-image", "Value is not used anymore"),
+		f.MarkDeprecated("operator.metrics-exporter-image", "Value is not used anymore"),
+		f.MarkDeprecated("operator.arango-image", "Value is not used anymore"),
+		f.MarkDeprecated("scope", "Value is not used anymore"),
+		f.MarkDeprecated("image.discovery.status", "Value fetched from the Operator Spec"),
+	); err != nil {
+		return errors.Wrap(err, "Unable to mark flags as deprecated")
 	}
-	if err := reconcile.ActionsConfigGlobal.Init(&cmdMain); err != nil {
-		panic(err.Error())
+
+	if err := errors.Errors(
+		f.MarkHidden("scope"),
+	); err != nil {
+		return errors.Wrap(err, "Unable to mark flags as hidden")
 	}
-	if err := operatorHTTP.InitConfiguration(&cmdMain); err != nil {
-		panic(err.Error())
+
+	if err := errors.Errors(
+		logging.Init(&cmdMain),
+		features.Init(&cmdMain),
+		agencyConfig.Init(&cmdMain),
+		reconcile.ActionsConfigGlobal.Init(&cmdMain),
+		operatorHTTP.InitConfiguration(&cmdMain),
+	); err != nil {
+		return errors.Wrap(err, "Unable to register secondary commands")
 	}
+
+	return nil
 }
 
 func Command() *cobra.Command {
@@ -590,7 +605,7 @@ func newOperatorConfigAndDeps(id, namespace, name string) (operator.Config, oper
 		Namespace:                   namespace,
 		PodName:                     name,
 		ServiceAccount:              serviceAccount,
-		OperatorImage:               image,
+		Image:                       image,
 		SkipLeaderLabel:             operatorOptions.skipLeaderLabel,
 		EnableDeployment:            operatorOptions.enableDeployment,
 		EnableDeploymentReplication: operatorOptions.enableDeploymentReplication,
@@ -633,18 +648,24 @@ func newOperatorConfigAndDeps(id, namespace, name string) (operator.Config, oper
 
 // getMyPodInfo looks up the image & service account of the pod with given name in given namespace
 // Returns image, serviceAccount, error.
-func getMyPodInfo(kubecli kubernetes.Interface, namespace, name string) (string, string, error) {
-	if image, sa, ok := getMyPodInfoWrap(kubecli, namespace, name, getMyImageInfoFunc(operatorImageDiscovery.defaultStatusDiscovery)); ok {
-		return image, sa, nil
-	}
+func getMyPodInfo(kubecli kubernetes.Interface, namespace, name string) (util.Image, string, error) {
+	var ret util.Image
+	var serviceAccount string
 
-	logger.Warn("Unable to discover image, fallback to second method")
+	if image, sa, ok := getMyPodInfoWrap(kubecli, namespace, name, getMyImageInfoFunc(false)); !ok {
+		return util.Image{}, "", errors.Errorf("Unable to discover Operator image from Spec")
+	} else {
+		ret.Image = image
+		serviceAccount = sa
+	}
 
-	if image, sa, ok := getMyPodInfoWrap(kubecli, namespace, name, getMyImageInfoFunc(!operatorImageDiscovery.defaultStatusDiscovery)); ok {
-		return image, sa, nil
+	if image, _, ok := getMyPodInfoWrap(kubecli, namespace, name, getMyImageInfoFunc(!operatorImageDiscovery.defaultStatusDiscovery)); ok {
+		ret.StatusImage = util.NewType(image)
+	} else {
+		logger.Warn("Unable to discover image from status")
 	}
 
-	return "", "", errors.Errorf("Unable to discover image")
+	return ret, serviceAccount, nil
 }
 
 func getMyPodInfoWrap(kubecli kubernetes.Interface, namespace, name string, imageFunc func(in *core.Pod) (string, bool)) (string, string, bool) {

docs/cli/arangodb_operator.md

@@ -78,7 +78,6 @@ Flags:
       --http1.transport.keep-alive-timeout-short duration      Interval between keep-alive probes for an active network connection (default 100ms)
       --http1.transport.max-idle-conns int                     Maximum number of idle (keep-alive) connections across all hosts. Zero means no limit (default 100)
       --http1.transport.tls-handshake-timeout duration         Maximum amount of time to wait for a TLS handshake. Zero means no timeout (default 10s)
-      --image.discovery.status                                 Discover Operator Image from Pod Status by default. When disabled Pod Spec is used. (default true)
       --image.discovery.timeout duration                       Timeout for image discovery process (default 1m0s)
       --internal.scaling-integration                           Enable Scaling Integration
       --kubernetes.burst int                                   Burst for the k8s API (default 256)

integrations/scheduler/v2/suite_test.go

@@ -32,6 +32,7 @@ import (
 	"github.com/arangodb/kube-arangodb/pkg/logging"
 	operator "github.com/arangodb/kube-arangodb/pkg/operatorV2"
 	"github.com/arangodb/kube-arangodb/pkg/operatorV2/event"
+	"github.com/arangodb/kube-arangodb/pkg/util"
 	"github.com/arangodb/kube-arangodb/pkg/util/k8sutil/helm"
 	"github.com/arangodb/kube-arangodb/pkg/util/kclient"
 	"github.com/arangodb/kube-arangodb/pkg/util/kclient/external"
@@ -102,7 +103,7 @@ func MockClient(t *testing.T, ctx context.Context, mods ...Mod) (pbSchedulerV2.S
 }
 
 func chartHandler(client kclient.Client, ns string) operator.Handler {
-	op := operator.NewOperator("mock", ns, "mock")
+	op := operator.NewOperator("mock", ns, util.Image{Image: "mock"})
 	recorder := event.NewEventRecorder("mock", client.Kubernetes())
 
 	return chart.Handler(op, recorder, client)

pkg/deployment/context_impl.go

@@ -84,7 +84,7 @@ func (d *Deployment) GetServerGroupIterator() reconciler.ServerGroupIterator {
 }
 
 func (d *Deployment) GetOperatorImage() string {
-	return d.config.OperatorImage
+	return d.config.Image.Get(d.GetSpec().ImageDiscoveryMode.Get() == api.DeploymentImageDiscoveryKubeletMode)
 }
 
 // GetNamespace returns the kubernetes namespace that contains

pkg/deployment/deployment.go

@@ -71,7 +71,7 @@ type Config struct {
 	ServiceAccount            string
 	AllowChaos                bool
 	ScalingIntegrationEnabled bool
-	OperatorImage             string
+	Image                     util.Image
 	ReconciliationDelay       time.Duration
 }
 

pkg/deployment/deployment_core_test.go

@@ -459,7 +459,7 @@ func TestEnsurePod_ArangoDB_Core(t *testing.T) {
 				},
 			},
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			Helper: func(t *testing.T, deployment *Deployment, testCase *testCaseStruct) {
 				deployment.currentObjectStatus = &api.DeploymentStatus{
@@ -690,7 +690,7 @@ func TestEnsurePod_ArangoDB_Core(t *testing.T) {
 				},
 			},
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			Helper: func(t *testing.T, deployment *Deployment, testCase *testCaseStruct) {
 				deployment.currentObjectStatus = &api.DeploymentStatus{
@@ -1237,7 +1237,7 @@ func TestEnsurePod_ArangoDB_Core(t *testing.T) {
 				testCase.ExpectedPod.Spec.Containers[0].LivenessProbe = createTestLivenessProbe(httpProbe, false, authorization, shared.ServerPortName)
 			},
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ExpectedEvent: "member dbserver is created",
 			ExpectedPod: core.Pod{
@@ -1307,7 +1307,7 @@ func TestEnsurePod_ArangoDB_Core(t *testing.T) {
 				testCase.ExpectedPod.Spec.Containers[0].LivenessProbe = createTestLivenessProbe(httpProbe, false, authorization, shared.ServerPortName)
 			},
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ExpectedEvent: "member dbserver is created",
 			ExpectedPod: core.Pod{

pkg/deployment/deployment_encryption_test.go

@@ -1,7 +1,7 @@
 //
 // DISCLAIMER
 //
-// Copyright 2016-2023 ArangoDB GmbH, Cologne, Germany
+// Copyright 2016-2025 ArangoDB GmbH, Cologne, Germany
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -132,7 +132,7 @@ func TestEnsurePod_ArangoDB_Encryption(t *testing.T) {
 				testCase.ExpectedPod.Spec.Containers[0].LivenessProbe = createTestLivenessProbe(httpProbe, true, authorization, shared.ServerPortName)
 			},
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ExpectedEvent: "member dbserver is created",
 			ExpectedPod: core.Pod{

pkg/deployment/deployment_pod_sync_test.go

@@ -289,7 +289,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod with lifecycle, license, monitoring without authentication and alpine",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -377,7 +377,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, ClusterIP and valid name",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -489,7 +489,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - missing service and valid name",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -582,7 +582,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, missing ClusterIP and valid name",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -683,7 +683,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, ClusterIP and invalid name",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -787,7 +787,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, ClusterIP and missing name",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -886,7 +886,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, ClusterIP and valid names",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -1002,7 +1002,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, ClusterIP and valid names with different ports",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -1116,7 +1116,7 @@ func TestEnsurePod_Sync_Master(t *testing.T) {
 			DropInit: true,
 			Name:     "Sync Master Pod alias - existing service, ClusterIP and mixed names",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -1239,7 +1239,7 @@ func TestEnsurePod_Sync_Worker(t *testing.T) {
 			Name: "Sync Worker Pod with monitoring, service account, node selector, lifecycle, license " +
 				"liveness probe, priority class name, resource requirements without alpine",
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{
@@ -1334,7 +1334,7 @@ func TestEnsurePod_Sync_Worker(t *testing.T) {
 				InitContainersCopyResources: util.NewType(false),
 			},
 			config: Config{
-				OperatorImage: testImageOperator,
+				Image: util.Image{Image: testImageOperator},
 			},
 			ArangoDeployment: &api.ArangoDeployment{
 				Spec: api.DeploymentSpec{