Files
2026-06-05 17:26:44 +08:00

20 lines
456 B
Go

package web
import (
"context"
"speedtest/internal/probe"
)
func DefaultRunner(ctx context.Context, request TestRequest, emit func(Event) error) (probe.Summary, error) {
return probe.Run(ctx, probe.Config{
Target: request.Target,
HTTPURL: request.HTTPURL,
Duration: request.Duration,
Interval: request.Interval,
Timeout: request.Timeout,
}, func(sample probe.Sample) error {
return emit(Event{Type: "sample", Sample: &sample})
})
}