attach flush duration metadata to sinks.FlushCompleteMessage
@@ -161,6 +161,7 @@ func (s *Server) Flush(ctx context.Context) {
"flushed": flushResult.MetricsFlushed,
"skipped": flushResult.MetricsSkipped,
"dropped": flushResult.MetricsDropped,
+ "duration_s": fmt.Sprintf("%.2f", time.Since(flushStart).Seconds()),
}
if err == nil {
s.logger.WithFields(flushCompleteMessageFields).WithField("success", true).Info(sinks.FlushCompleteMessage)
