From b443774a4bf5314fc0d8fc08a8d2ae6da23cafad Mon Sep 17 00:00:00 2001 From: Jaakko Heusala Date: Sun, 20 Oct 2024 23:09:18 +0300 Subject: [PATCH] Better statistics - part 3 https://github.com/hyperifyio/statelessdb/issues/30 --- pkg/workers/pool.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/workers/pool.go b/pkg/workers/pool.go index 8e2b4cf..fa8eeb9 100644 --- a/pkg/workers/pool.go +++ b/pkg/workers/pool.go @@ -169,6 +169,7 @@ func (m *WorkerPool[T]) Start(workers int, f func(T)) error { diffPublishedCount, jobsPublishedSecond, diffStartedCount, jobsStartedSecond, diffFinishedCount, jobsFinishedSecond, currentJobsWaiting, diffJobsWaiting, currentJobsProcessing, diffJobsProcessing) } + prevTime = currentTime prevPublishedCount = m.PublishedJobs() prevStartedCount = m.StartedJobs() prevFinishedCount = m.FinishedJobs()