[feature] export module versions to DOP via mm_module_enabled metric (#752)

Signed-off-by: Artem Kuleshov <artem.kuleshov@flant.com>

Author: Fkuloff

pkg/labels.go

@@ -126,4 +126,5 @@ const (
 	MetricKeyOperation  = "operation"
 	MetricKeyQueue      = "queue"
 	MetricKeyResource   = "resource"
+	MetricKeyVersion    = "version"
 )

pkg/metrics/metrics.go

@@ -45,6 +45,12 @@ var (
 	ModulesAbsentResourcesTotal = "{PREFIX}modules_absent_resources_total"
 	// ModuleInfoMetricName tracks module information
 	ModuleInfoMetricName = "{PREFIX}mm_module_info"
+	// ModuleEnabledMetricName tracks enabled modules with their deployed version
+	ModuleEnabledMetricName = "{PREFIX}mm_module_enabled"
+	// ModuleEnabledTelemetryMetricName mirrors ModuleEnabledMetricName under the
+	// d8_telemetry_ prefix so flant-integration ships the metric to DOP.
+	// The prefix is literal here (no {PREFIX} placeholder) and must stay that way.
+	ModuleEnabledTelemetryMetricName = "d8_telemetry_module_enabled"
 	// ModuleMaintenanceMetricName tracks module maintenance state
 	ModuleMaintenanceMetricName = "{PREFIX}mm_module_maintenance"
 
@@ -154,6 +160,7 @@ func InitMetrics(prefix string) {
 	ModulesHelmReleaseRedeployedTotal = ReplacePrefix(ModulesHelmReleaseRedeployedTotal, prefix)
 	ModulesAbsentResourcesTotal = ReplacePrefix(ModulesAbsentResourcesTotal, prefix)
 	ModuleInfoMetricName = ReplacePrefix(ModuleInfoMetricName, prefix)
+	ModuleEnabledMetricName = ReplacePrefix(ModuleEnabledMetricName, prefix)
 	ModuleMaintenanceMetricName = ReplacePrefix(ModuleMaintenanceMetricName, prefix)
 
 	// ============================================================================

pkg/module_manager/models/modules/basic.go

@@ -54,6 +54,8 @@ type BasicModule struct {
 	// required
 	Path string
 
+	version string
+
 	critical bool
 
 	crdsExist     bool
@@ -120,6 +122,14 @@ func (bm *BasicModule) SetCritical(value bool) {
 	bm.critical = value
 }
 
+func (bm *BasicModule) SetVersion(v string) {
+	bm.version = v
+}
+
+func (bm *BasicModule) GetVersion() string {
+	return bm.version
+}
+
 // getCRDsFromPath scan path/crds directory and store yaml file in slice
 // if file name do not start with `_` or `doc-` prefix
 func getCRDsFromPath(path string, crdsFilters string) []string {

pkg/module_manager/module_manager.go

@@ -52,6 +52,7 @@ import (
 
 var (
 	moduleInfoMetricGroup        = "mm_module_info"
+	moduleEnabledMetricGroup     = "mm_module_enabled"
 	moduleMaintenanceMetricGroup = "mm_module_maintenance"
 	moduleManagerServiceName     = "module-manager"
 )
@@ -513,6 +514,38 @@ func (mm *ModuleManager) UpdateModulesMetrics() {
 
 		mm.dependencies.MetricStorage.Grouped().GaugeSet(moduleInfoMetricGroup, metrics.ModuleInfoMetricName, 1, map[string]string{pkg.MetricKeyModule: module, "enabled": enabled})
 	}
+
+	mm.refreshModuleEnabledMetric()
+}
+
+func (mm *ModuleManager) refreshModuleEnabledMetric() {
+	mm.dependencies.MetricStorage.Grouped().ExpireGroupMetrics(moduleEnabledMetricGroup)
+
+	for _, name := range mm.GetModuleNames() {
+		if !mm.IsModuleEnabled(name) {
+			continue
+		}
+
+		mod := mm.GetModule(name)
+		if mod == nil {
+			continue
+		}
+
+		version := mod.GetVersion()
+		if version == "" {
+			continue
+		}
+
+		labels := map[string]string{
+			pkg.MetricKeyModule:  name,
+			pkg.MetricKeyVersion: version,
+		}
+		mm.dependencies.MetricStorage.Grouped().GaugeSet(moduleEnabledMetricGroup, metrics.ModuleEnabledMetricName, 1, labels)
+		// Telemetry twin: same gauge under the d8_telemetry_ prefix so
+		// flant-integration ships it to DOP. Kept in the same group so
+		// ExpireGroupMetrics above wipes both copies in lockstep.
+		mm.dependencies.MetricStorage.Grouped().GaugeSet(moduleEnabledMetricGroup, metrics.ModuleEnabledTelemetryMetricName, 1, labels)
+	}
 }
 
 func (mm *ModuleManager) SetModuleMaintenanceState(moduleName string, state utils.Maintenance) {