feat: Add k8s client config option to scope namespace

Signed-off-by: Graham Beckley <[email protected]>

Author: grahamalama

cmd/run.go

@@ -259,7 +259,7 @@ func runImageUpdater(cfg *ImageUpdaterConfig, warmUp bool) (argocd.ImageUpdaterR
 	var argoClient argocd.ArgoCD
 	switch cfg.ApplicationsAPIKind {
 	case applicationsAPIKindK8S:
-		argoClient, err = argocd.NewK8SClient(cfg.KubeClient)
+		argoClient, err = argocd.NewK8SClient(cfg.KubeClient, &argocd.K8SClientOptions{AppNamespace: cfg.AppNamespace})
 	case applicationsAPIKindArgoCD:
 		argoClient, err = argocd.NewAPIClient(&cfg.ClientOpts)
 	default:

pkg/argocd/argocd.go

@@ -25,13 +25,14 @@ import (
 
 // Kubernetes based client
 type k8sClient struct {
-	kubeClient *kube.ImageUpdaterKubernetesClient
+	kubeClient   *kube.ImageUpdaterKubernetesClient
+	appNamespace *string
 }
 
 // GetApplication retrieves an application by name across all namespaces.
 func (client *k8sClient) GetApplication(ctx context.Context, appName string) (*v1alpha1.Application, error) {
-	// List all applications across all namespaces (using empty labelSelector)
-	appList, err := client.ListApplications(v1.NamespaceAll)
+	// List all applications across configured namespace or all namespaces (using empty labelSelector)
+	appList, err := client.ListApplications("")
 	if err != nil {
 		return nil, fmt.Errorf("error listing applications: %w", err)
 	}
@@ -61,7 +62,7 @@ func (client *k8sClient) GetApplication(ctx context.Context, appName string) (*v
 
 // ListApplications lists all applications across all namespaces.
 func (client *k8sClient) ListApplications(labelSelector string) ([]v1alpha1.Application, error) {
-	list, err := client.kubeClient.ApplicationsClientset.ArgoprojV1alpha1().Applications(v1.NamespaceAll).List(context.TODO(), v1.ListOptions{LabelSelector: labelSelector})
+	list, err := client.kubeClient.ApplicationsClientset.ArgoprojV1alpha1().Applications(*client.appNamespace).List(context.TODO(), v1.ListOptions{LabelSelector: labelSelector})
 	if err != nil {
 		return nil, fmt.Errorf("error listing applications: %w", err)
 	}
@@ -99,9 +100,23 @@ func (client *k8sClient) UpdateSpec(ctx context.Context, spec *application.Appli
 	return nil, fmt.Errorf("max retries(%d) reached while updating application: %s", maxRetries, spec.GetName())
 }
 
+type K8SClientOptions struct {
+	AppNamespace string
+}
+
 // NewK8SClient creates a new kubernetes client to interact with kubernetes api-server.
-func NewK8SClient(kubeClient *kube.ImageUpdaterKubernetesClient) (ArgoCD, error) {
-	return &k8sClient{kubeClient: kubeClient}, nil
+func NewK8SClient(kubeClient *kube.ImageUpdaterKubernetesClient, opts *K8SClientOptions) (ArgoCD, error) {
+	// Provide default options if nil
+	if opts == nil {
+		opts = &K8SClientOptions{
+			AppNamespace: v1.NamespaceAll,
+		}
+	}
+
+	return &k8sClient{
+		kubeClient:   kubeClient,
+		appNamespace: &opts.AppNamespace,
+	}, nil
 }
 
 // Native

pkg/argocd/argocd_test.go

@@ -1023,7 +1023,7 @@ func TestKubernetesClient(t *testing.T) {
 			Namespace: "testns1",
 		},
 		ApplicationsClientset: fake.NewSimpleClientset(app1, app2),
-	})
+	}, nil)
 
 	require.NoError(t, err)
 
@@ -1064,7 +1064,7 @@ func TestKubernetesClient(t *testing.T) {
 		// Create the Kubernetes client
 		client, err := NewK8SClient(&kube.ImageUpdaterKubernetesClient{
 			ApplicationsClientset: clientset,
-		})
+		}, nil)
 		require.NoError(t, err)
 
 		// Test ListApplications error handling
@@ -1094,7 +1094,7 @@ func TestKubernetesClient(t *testing.T) {
 		// Create the Kubernetes client
 		client, err := NewK8SClient(&kube.ImageUpdaterKubernetesClient{
 			ApplicationsClientset: clientset,
-		})
+		}, nil)
 		require.NoError(t, err)
 
 		// Test GetApplication with multiple matching applications
@@ -1124,7 +1124,7 @@ func TestKubernetesClientUpdateSpec(t *testing.T) {
 
 		client, err := NewK8SClient(&kube.ImageUpdaterKubernetesClient{
 			ApplicationsClientset: clientset,
-		})
+		}, nil)
 		require.NoError(t, err)
 
 		appName := "test-app"
@@ -1145,7 +1145,7 @@ func TestKubernetesClientUpdateSpec(t *testing.T) {
 
 		client, err := NewK8SClient(&kube.ImageUpdaterKubernetesClient{
 			ApplicationsClientset: clientset,
-		})
+		}, nil)
 		require.NoError(t, err)
 
 		appName := "test-app"
@@ -1169,7 +1169,7 @@ func TestKubernetesClientUpdateSpec(t *testing.T) {
 
 		client, err := NewK8SClient(&kube.ImageUpdaterKubernetesClient{
 			ApplicationsClientset: clientset,
-		})
+		}, nil)
 		require.NoError(t, err)
 
 		clientset.PrependReactor("update", "applications", func(action k8stesting.Action) (handled bool, ret runtime.Object, err error) {
@@ -1198,7 +1198,7 @@ func TestKubernetesClientUpdateSpec(t *testing.T) {
 
 		client, err := NewK8SClient(&kube.ImageUpdaterKubernetesClient{
 			ApplicationsClientset: clientset,
-		})
+		}, nil)
 		require.NoError(t, err)
 
 		clientset.PrependReactor("update", "applications", func(action k8stesting.Action) (handled bool, ret runtime.Object, err error) {