labels

Signed-off-by: Nikolay Demchuk <[email protected]>

images/agent/pkg/controller/lvm_volume_group_watcher.go

@@ -43,6 +43,7 @@ import (
 
 const (
 	LVMVolumeGroupWatcherCtrlName = "lvm-volume-group-watcher-controller"
+	LVGHostnameLabelKey           = "kubernetes.io/metadata.name"
 )
 
 func RunLVMVolumeGroupWatcherController(

images/agent/pkg/controller/lvm_volume_group_watcher_func.go

@@ -73,12 +73,39 @@ func checkIfVGExist(vgName string, vgs []internal.VGData) bool {
 	return false
 }
 
+func checkLabels(log logger.Logger, newLVG *v1alpha1.LvmVolumeGroup) bool {
+
+	if newLVG.Labels == nil {
+		log.Debug(fmt.Sprintf("[shouldLVGWatcherReconcileUpdateEvent] update event should be reconciled as the LVMVolumeGroup %s has no labels", newLVG.Name))
+		return false
+	}
+
+	labelValue, exist := newLVG.Labels[LVGHostnameLabelKey]
+
+	if !exist {
+		log.Debug(fmt.Sprintf("[shouldLVGWatcherReconcileUpdateEvent] update event should be reconciled as the LVMVolumeGroup %s has no label %s", newLVG.Name, LVGHostnameLabelKey))
+		return false
+	}
+
+	if labelValue != newLVG.Name {
+		log.Debug(fmt.Sprintf("[shouldLVGWatcherReconcileUpdateEvent] update event should be reconciled as the LVMVolumeGroup %s has label %s but the value is incorrect - %q, but should be %q", newLVG.Name, LVGHostnameLabelKey, labelValue, newLVG.Name))
+		return false
+	}
+
+	return true
+}
+
 func shouldLVGWatcherReconcileUpdateEvent(log logger.Logger, oldLVG, newLVG *v1alpha1.LvmVolumeGroup) bool {
 	if newLVG.DeletionTimestamp != nil {
 		log.Debug(fmt.Sprintf("[shouldLVGWatcherReconcileUpdateEvent] update event should be reconciled as the LVMVolumeGroup %s has deletionTimestamp", newLVG.Name))
 		return true
 	}
 
+	if !checkLabels(log, newLVG) {
+		log.Debug(fmt.Sprintf("[shouldLVGWatcherReconcileUpdateEvent] update event should be reconciled as the LVMVolumeGroup's %s labels have been changed", newLVG.Name))
+		return true
+	}
+
 	if !reflect.DeepEqual(oldLVG.Spec, newLVG.Spec) {
 		log.Debug(fmt.Sprintf("[shouldLVGWatcherReconcileUpdateEvent] update event should be reconciled as the LVMVolumeGroup %s configuration has been changed", newLVG.Name))
 		return true