xk6-frostfs/internal/stats/stats.go

36 lines
701 B
Go
Raw Permalink Normal View History

package stats
import (
"time"
"go.k6.io/k6/js/modules"
"go.k6.io/k6/metrics"
)
func Report(vu modules.VU, metric *metrics.Metric, value float64) {
metrics.PushIfNotDone(vu.Context(), vu.State().Samples, metrics.Sample{
Metric: metric,
Time: time.Now(),
Value: value,
})
}
func ReportDataReceived(vu modules.VU, value float64) {
vu.State().BuiltinMetrics.DataReceived.Sink.Add(
metrics.Sample{
Metric: &metrics.Metric{},
Value: value,
Time: time.Now()},
)
}
func ReportDataSent(vu modules.VU, value float64) {
state := vu.State()
state.BuiltinMetrics.DataSent.Sink.Add(
metrics.Sample{
Metric: &metrics.Metric{},
Value: value,
Time: time.Now()},
)
}