BootID support for KMM

Author: sriram-30

api/v1beta1/nodemodulesconfig_types.go

@@ -68,6 +68,8 @@ type NodeModuleStatus struct {
 	Config ModuleConfig `json:"config,omitempty"`
 	//+optional
 	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
+	//+optional
+	BootId string `json:"bootId,omitempty"`
 }
 
 // NodeModuleConfigStatus is the most recently observed status of the KMM modules on node.

config/crd/bases/kmm.sigs.x-k8s.io_nodemodulesconfigs.yaml

@@ -241,6 +241,8 @@ spec:
                   state status
                 items:
                   properties:
+                    bootId:
+                      type: string
                     config:
                       properties:
                         containerImage:

internal/controllers/nmc_reconciler.go

@@ -374,7 +374,12 @@ func (h *nmcReconcilerHelperImpl) ProcessModuleSpec(
 			return h.podManager.CreateLoaderPod(ctx, nmcObj, spec)
 		}
 
-		if h.nodeAPI.NodeBecomeReadyAfter(node, status.LastTransitionTime) {
+		currentBootId := node.Status.NodeInfo.BootID
+		bootIdChanged := status.BootId != currentBootId
+		if bootIdChanged {
+			logger.Info("Detected BootId change")
+		}
+		if bootIdChanged || h.nodeAPI.NodeBecomeReadyAfter(node, status.LastTransitionTime) {
 			logger.Info("node has been rebooted and become ready after kernel module was loaded; creating loader Pod")
 			return h.podManager.CreateLoaderPod(ctx, nmcObj, spec)
 		}
@@ -578,6 +583,12 @@ func (h *nmcReconcilerHelperImpl) SyncStatus(ctx context.Context, nmcObj *kmmv1b
 				Terminated.
 				FinishedAt
 
+			node := &v1.Node{}
+			if err := h.client.Get(ctx, types.NamespacedName{Name: nmcObj.Name}, node); err != nil {
+				logger.Error(err, "Failed to get node object", "node", nmcObj.Name)
+			} else {
+				status.BootId = node.Status.NodeInfo.BootID
+			}
 			status.LastTransitionTime = podLTT
 
 			nmc.SetModuleStatus(&nmcObj.Status.Modules, *status)