More accurate TOTAL rates

rabbitmq · Dec 17, 2024 · a982571 · a982571
1 parent 6e02254
commit a982571
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/cmd/root.go b/cmd/root.go
@@ -373,6 +373,7 @@ func start(cfg config.Config) {
 
 	startPublishing := make(chan bool)
 	startPublishers(ctx, &wg, startPublishing)
+	metricsServer.StartTime(time.Now())
 	close(startPublishing)
 
 	if cfg.Duration > 0 {

diff --git a/pkg/metrics/metrics.go b/pkg/metrics/metrics.go
@@ -66,7 +66,7 @@ func Start(ctx context.Context, cfg config.Config) *MetricsServer {
 
 	go func() {
 		for {
-			metricsServer.started = time.Now()
+			metricsServer.started = time.Now() // updated later for higher accuracy
 			log.Debug("starting Prometheus metrics server", "address", metricsServer.httpServer.Addr)
 			err := metricsServer.httpServer.ListenAndServe()
 			if errors.Is(err, syscall.EADDRINUSE) {
@@ -168,6 +168,10 @@ func (m *MetricsServer) printMessageRates(ctx context.Context) {
 	}()
 }
 
+func (m *MetricsServer) StartTime(t time.Time) {
+	m.started = t
+}
+
 func (m *MetricsServer) Stop() {
 	m.PrintSummary()
 	if m.printAllOnStop {