nfd-worker: Add an option to disable setting the owner references

cmd/nfd-worker/main.go

@@ -134,6 +134,8 @@ func initFlags(flagset *flag.FlagSet) (*worker.Args, *worker.ConfigOverrideArgs)
 			" DEPRECATED: will be removed in a future release along with the deprecated gRPC API.")
 	flagset.StringVar(&args.Kubeconfig, "kubeconfig", "",
 		"Kubeconfig to use")
+	flagset.BoolVar(&args.NoOwnerRefs, "no-owner-refs", false,
+		"Do not set owner references for NodeFeature object")
 	flagset.BoolVar(&args.Oneshot, "oneshot", false,
 		"Do not publish feature labels")
 	flagset.IntVar(&args.MetricsPort, "metrics", 8081,

docs/reference/worker-commandline-reference.md

@@ -253,6 +253,23 @@ Example:
 nfd-worker -no-publish
 ```
 
+### -no-owner-refs
+
+The `-no-owner-refs` flag disables setting the owner references to Pod
+for NodeFeature object.
+
+> **NOTE:** This flag takes precedence over the
+> [`core.noOwnerRefs`](worker-configuration-reference.md#corenoownerrefs)
+> configuration file option.
+
+Default: *false*
+
+Example:
+
+```bash
+nfd-worker -no-owner-refs
+```
+
 ### -oneshot
 
 The `-oneshot` flag causes nfd-worker to exit after one pass of feature

docs/reference/worker-configuration-reference.md

@@ -149,6 +149,24 @@ core:
   noPublish: true
 ```
 
+### core.noOwnerRefs
+
+Setting `core.noOwnerRefs` to `true` disables setting the owner references
+to Pod for NodeFeature object.
+
+> **NOTE:** Overridden by the
+> [`-no-owner-refs`](worker-commandline-reference.md#-no-owner-refs)
+> command line flag (if specified).
+
+Default: `false`
+
+Example:
+
+```yaml
+core:
+  noOwnerRefs: true
+```
+
 ### core.klog
 
 The following options specify the logger configuration.

pkg/nfd-worker/nfd-worker.go

@@ -84,6 +84,7 @@ type coreConfig struct {
 	Klog           klogutils.KlogConfigOpts
 	LabelWhiteList utils.RegexpVal
 	NoPublish      bool
+	NoOwnerRefs    bool
 	FeatureSources []string
 	Sources        *[]string
 	LabelSources   []string
@@ -103,6 +104,7 @@ type Args struct {
 	KeyFile            string
 	Klog               map[string]*utils.KlogFlagVal
 	Kubeconfig         string
+	NoOwnerRefs        bool
 	Oneshot            bool
 	Options            string
 	Server             string
@@ -292,32 +294,9 @@ func (w *nfdWorker) runFeatureDiscovery() error {
 	return nil
 }
 
-// Run NfdWorker client. Returns if a fatal error is encountered, or, after
-// one request if OneShot is set to 'true' in the worker args.
-func (w *nfdWorker) Run() error {
-	klog.InfoS("Node Feature Discovery Worker", "version", version.Get(), "nodeName", utils.NodeName(), "namespace", w.kubernetesNamespace)
-
-	// Read configuration file
-	err := w.configure(w.configFilePath, w.args.Options)
-	if err != nil {
-		return err
-	}
-
-	// Create watcher for TLS certificates
-	w.certWatch, err = utils.CreateFsWatcher(time.Second, w.args.CaFile, w.args.CertFile, w.args.KeyFile)
-	if err != nil {
-		return err
-	}
-
-	defer w.grpcDisconnect()
-
-	// Create ticker for feature discovery and run feature discovery once before the loop.
-	labelTrigger := infiniteTicker{Ticker: time.NewTicker(1)}
-	labelTrigger.Reset(w.config.Core.SleepInterval.Duration)
-	defer labelTrigger.Stop()
-
-	// Create owner ref
+func (w *nfdWorker) addOwnerReference() error {
 	ownerReference := []metav1.OwnerReference{}
+
 	// Get pod owner reference
 	podName := os.Getenv("POD_NAME")
 
@@ -347,6 +326,40 @@ func (w *nfdWorker) Run() error {
 
 	w.ownerReference = ownerReference
 
+	return nil
+}
+
+// Run NfdWorker client. Returns if a fatal error is encountered, or, after
+// one request if OneShot is set to 'true' in the worker args.
+func (w *nfdWorker) Run() error {
+	klog.InfoS("Node Feature Discovery Worker", "version", version.Get(), "nodeName", utils.NodeName(), "namespace", w.kubernetesNamespace)
+
+	// Read configuration file
+	err := w.configure(w.configFilePath, w.args.Options)
+	if err != nil {
+		return err
+	}
+
+	// Create watcher for TLS certificates
+	w.certWatch, err = utils.CreateFsWatcher(time.Second, w.args.CaFile, w.args.CertFile, w.args.KeyFile)
+	if err != nil {
+		return err
+	}
+
+	defer w.grpcDisconnect()
+
+	// Create ticker for feature discovery and run feature discovery once before the loop.
+	labelTrigger := infiniteTicker{Ticker: time.NewTicker(1)}
+	labelTrigger.Reset(w.config.Core.SleepInterval.Duration)
+	defer labelTrigger.Stop()
+
+	if !w.config.Core.NoOwnerRefs {
+		err := w.addOwnerReference()
+		if err != nil {
+			return err
+		}
+	}
+
 	// Register to metrics server
 	if w.args.MetricsPort > 0 {
 		m := utils.CreateMetricsServer(w.args.MetricsPort,