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

In some cases it's desirable to control automatic garbage collection
of NodeFeature object.

Add an option to disable setting the owner references to Pod
for NodeFeature object.

Closes: 1817

Signed-off-by: Oleg Zhurakivskyy <oleg.zhurakivskyy@intel.com>

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,