Function Random

tests/random/random.go:33–98

(ctx context.Context, secrets string, n int, proxyHost string)

}

func Random(ctx context.Context, secrets string, n int, proxyHost string) error {
	l := zerolog.Ctx(ctx)

	if secrets == "" {
		return errors.New("secrets required")
	}

	if n <= 0 {
		return errors.New("node count must be positive")
	}

	if proxyHost == "" {
		return errors.New("proxy host required")
	}

	secretValue := strings.TrimSpace(secrets)

	// Parse the SAS URLs from the secret value
	upstreamSasUrls := strings.Fields(secretValue)
	p2pSasUrls := getP2pSasUrls(strings.Fields(secretValue), proxyHost)

	var g errgroup.Group
	var upstreamPercentiles, p2pPercentiles []float64
	var upstreamErrorRate, p2pErrorRate float64

	g.Go(func() error {
		upstreamPercentiles, upstreamErrorRate = benchmark(l, "upstream", upstreamSasUrls, n)
		return nil
	})

	delay(l)

	g.Go(func() error {
		p2pPercentiles, p2pErrorRate = benchmark(l, "p2p", p2pSasUrls, n)
		return nil
	})

	_ = g.Wait()

	// Print the results
	if len(upstreamPercentiles) > 0 {
		l.Info().
			Float64("upstream.p50", upstreamPercentiles[0]).
			Float64("upstream.p75", upstreamPercentiles[1]).
			Float64("upstream.p90", upstreamPercentiles[2]).
			Float64("upstream.p95", upstreamPercentiles[3]).
			Float64("upstream.p100", upstreamPercentiles[4]).
			Msg("speeds (MB/s)")
	}

	if len(p2pPercentiles) > 0 {
		l.Info().
			Float64("p2p.p50", p2pPercentiles[0]).
			Float64("p2p.p75", p2pPercentiles[1]).
			Float64("p2p.p90", p2pPercentiles[2]).
			Float64("p2p.p95", p2pPercentiles[3]).
			Float64("p2p.p100", p2pPercentiles[4]).
			Msg("speeds (MB/s)")