ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2026-07-22 01:00:38 +02:00
Code Issues Packages Projects Releases Wiki Activity

Actually send the created marker metrics

Browse Source
This commit is contained in:
Michael Panzlaff
2026-07-20 15:39:40 +02:00
parent 6124971b2e
commit c13bb55735
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
collectors/collectorManager.go
+12 -2
View File
@@ -151,7 +151,12 @@ func (cm *collectorManager) Start() {
return return
case t := <-tick: case t := <-tick:
if cm.enableMarkers { if cm.enableMarkers {
lp.NewMetric("ccmc-begin", map[string]string{"type": "node"}, nil, map[string]interface{}{"value": 0}, time.Now()) m, err := lp.NewMetric("ccmc-begin", map[string]string{"type": "node"}, nil, map[string]interface{}{"value": 0}, time.Now())
if err != nil {
cclog.ComponentErrorf("CollectorManager", "Unable to create marker metric: %v", err)
} else {
cm.output <- m
}
} }
cm.parallel_run = true cm.parallel_run = true
for _, c := range cm.collectors { for _, c := range cm.collectors {
@@ -185,7 +190,12 @@ func (cm *collectorManager) Start() {
} }
} }
if cm.enableMarkers { if cm.enableMarkers {
lp.NewMetric("ccmc-end", map[string]string{"type": "node"}, nil, map[string]interface{}{"value": 0}, time.Now()) m, err := lp.NewMetric("ccmc-end", map[string]string{"type": "node"}, nil, map[string]interface{}{"value": 0}, time.Now())
if err != nil {
cclog.ComponentErrorf("CollectorManager", "Unable to create marker metric: %v", err)
} else {
cm.output <- m
}
} }
} }
} }