From c13bb5573504e28f5a91677b530b23696d5f9e6e Mon Sep 17 00:00:00 2001 From: Michael Panzlaff Date: Mon, 20 Jul 2026 15:39:40 +0200 Subject: [PATCH] Actually send the created marker metrics --- collectors/collectorManager.go | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/collectors/collectorManager.go b/collectors/collectorManager.go index 75c3835..255e429 100644 --- a/collectors/collectorManager.go +++ b/collectors/collectorManager.go @@ -151,7 +151,12 @@ func (cm *collectorManager) Start() { return case t := <-tick: 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 for _, c := range cm.collectors { @@ -185,7 +190,12 @@ func (cm *collectorManager) Start() { } } 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 + } } } }