From cdac3c9163906b6d78bc51521dd00947ae51e216 Mon Sep 17 00:00:00 2001
From: Michael Panzlaff <michael.panzlaff@fau.de>
Date: Wed, 15 Jul 2026 15:35:30 +0200
Subject: [PATCH] Add ccmc-{begin,end} markers

These markers are sent out at the beginning and end of a collection run.
This can be used to reconstruct, which metrics belong together and were
obtained during the same tick.
---
 collectors/collectorManager.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/collectors/collectorManager.go b/collectors/collectorManager.go
index 9cce461..58f9a3c 100644
--- a/collectors/collectorManager.go
+++ b/collectors/collectorManager.go
@@ -148,6 +148,7 @@ func (cm *collectorManager) Start() {
 				done()
 				return
 			case t := <-tick:
+				lp.NewMetric("ccmc-begin", map[string]string{"type": "node"}, nil, map[string]interface{}{"value": 0}, time.Now())
 				cm.parallel_run = true
 				for _, c := range cm.collectors {
 					// Wait for done signal or execute the collector
@@ -179,6 +180,7 @@ func (cm *collectorManager) Start() {
 						c.Read(cm.duration, cm.output)
 					}
 				}
+				lp.NewMetric("ccmc-end", map[string]string{"type": "node"}, nil, map[string]interface{}{"value": 0}, time.Now())
 			}
 		}
 	})