(skywalking-banyandb) branch scheduler-metrics updated: Fix latency unit

[hanahmily]

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch scheduler-metrics
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git


The following commit(s) were added to refs/heads/scheduler-metrics by this push:
     new 49b87c8b Fix latency unit
49b87c8b is described below

commit 49b87c8b3082f117c954c4904ca5b42aeb40d62c
Author: Gao Hongtao <hanahm...@gmail.com>
AuthorDate: Sat Aug 24 00:17:41 2024 +0000

    Fix latency unit
    
    Signed-off-by: Gao Hongtao <hanahm...@gmail.com>
---
 banyand/observability/service.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/banyand/observability/service.go b/banyand/observability/service.go
index c08b9f10..593f9b04 100644
--- a/banyand/observability/service.go
+++ b/banyand/observability/service.go
@@ -246,5 +246,5 @@ func (sm *SchedulerMetrics) Collect(job string, m 
*timestamp.SchedulerMetrics) {
        sm.totalTasksStarted.Set(float64(m.TotalTasksStarted.Load()), job)
        sm.totalTasksFinished.Set(float64(m.TotalTasksFinished.Load()), job)
        sm.totalTasksPanic.Set(float64(m.TotalTasksPanic.Load()), job)
-       
sm.totalTaskLatency.Set(float64(m.TotalTaskLatencyInNanoseconds.Load()/int64(time.Second)),
 job)
+       
sm.totalTaskLatency.Set(float64(m.TotalTaskLatencyInNanoseconds.Load())/float64(time.Second),
 job)
 }