redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-12-03 18:31:14 +03:00
Code Activity

fix benchmark report

Browse Source
This commit is contained in:
Nedyalko Dyakov
2025-10-27 08:03:08 +02:00
parent 316aeb7b3c
commit da5fe33cdf
1 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
hset_benchmark_test.go
View File

@@ -101,7 +101,11 @@ func benchmarkHSETOperations(b *testing.B, rdb *redis.Client, ctx context.Contex
avgTimePerOp := b.Elapsed().Nanoseconds() / int64(operations*b.N) avgTimePerOp := b.Elapsed().Nanoseconds() / int64(operations*b.N)
b.ReportMetric(float64(avgTimePerOp), "ns/op") b.ReportMetric(float64(avgTimePerOp), "ns/op")
// report average time in milliseconds from totalTimes // report average time in milliseconds from totalTimes
avgTimePerOpMs := totalTimes[0].Milliseconds() / int64(len(totalTimes)) sumTime := time.Duration(0)
for _, t := range totalTimes {
sumTime += t
}
avgTimePerOpMs := sumTime.Milliseconds() / int64(len(totalTimes))
b.ReportMetric(float64(avgTimePerOpMs), "ms") b.ReportMetric(float64(avgTimePerOpMs), "ms")
} }
@@ -135,7 +139,7 @@ func benchmarkHSETOperationsConcurrent(b *testing.B, rdb *redis.Client, ctx cont
if err != nil { if err != nil {
b.Fatalf("HSET operation failed: %v", err) b.Fatalf("HSET operation failed: %v", err)
} }
timesCh <- time.Since(startTime)) timesCh <- time.Since(startTime)
}(j) }(j)
wg.Wait() wg.Wait()
close(timesCh) close(timesCh)
@@ -156,7 +160,12 @@ func benchmarkHSETOperationsConcurrent(b *testing.B, rdb *redis.Client, ctx cont
avgTimePerOp := b.Elapsed().Nanoseconds() / int64(operations*b.N) avgTimePerOp := b.Elapsed().Nanoseconds() / int64(operations*b.N)
b.ReportMetric(float64(avgTimePerOp), "ns/op") b.ReportMetric(float64(avgTimePerOp), "ns/op")
// report average time in milliseconds from totalTimes // report average time in milliseconds from totalTimes
avgTimePerOpMs := totalTimes[0].Milliseconds() / int64(len(totalTimes))
sumTime := time.Duration(0)
for _, t := range totalTimes {
sumTime += t
}
avgTimePerOpMs := sumTime.Milliseconds() / int64(len(totalTimes))
b.ReportMetric(float64(avgTimePerOpMs), "ms") b.ReportMetric(float64(avgTimePerOpMs), "ms")
} }
@@ -263,7 +272,11 @@ func benchmarkHSETPipelined(b *testing.B, rdb *redis.Client, ctx context.Context
avgTimePerOp := b.Elapsed().Nanoseconds() / int64(operations*b.N) avgTimePerOp := b.Elapsed().Nanoseconds() / int64(operations*b.N)
b.ReportMetric(float64(avgTimePerOp), "ns/op") b.ReportMetric(float64(avgTimePerOp), "ns/op")
// report average time in milliseconds from totalTimes // report average time in milliseconds from totalTimes
avgTimePerOpMs := totalTimes[0].Milliseconds() / int64(len(totalTimes)) sumTime := time.Duration(0)
for _, t := range totalTimes {
sumTime += t
}
avgTimePerOpMs := sumTime.Milliseconds() / int64(len(totalTimes))
b.ReportMetric(float64(avgTimePerOpMs), "ms") b.ReportMetric(float64(avgTimePerOpMs), "ms")
} }