fix: set kubeconfig for dynamic clients

flanksource · Dec 13, 2024 · 09e6bd0 · 09e6bd0
1 parent f4af6b3
commit 09e6bd0
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/scrapers/cron.go b/scrapers/cron.go
@@ -242,6 +242,14 @@ func scheduleScraperJob(sc api.ScrapeContext) error {
 			return fmt.Errorf("failed to watch kubernetes resources: %v", err)
 		}
 
+		if config.Kubeconfig != nil {
+			c, err := sc.WithKubeconfig(*config.Kubeconfig)
+			if err != nil {
+				return fmt.Errorf("failed to apply custom kubeconfig: %w", err)
+			}
+			sc.Context = *c
+
+		}
 		watchConsumerJob := ConsumeKubernetesWatchJobFunc(sc, config, queue)
 		if err := watchConsumerJob.AddToScheduler(scrapeJobScheduler); err != nil {
 			return fmt.Errorf("failed to schedule kubernetes watch consumer job: %v", err)