Implement test by URL for webrtc load test (#328)

* Implement test by URL for webrtc load test

* make it easier to click the link from a terminal

* implement as a string format

.gitignore

@@ -138,3 +138,5 @@ tags
 /testdriver
 /recordtester
 /api-transcoder
+
+webrtc-load-tester.conf

cmd/webrtc-load-tester/roles/orchestrator.go

@@ -40,6 +40,7 @@ type loadTestArguments struct {
 	}
 	Playback struct {
 		BaseURL             string
+		ManifestURL         string
 		RegionViewersJSON   map[string]int
 		ViewersPerWorker    int
 		MemoryPerViewerMiB  int
@@ -67,6 +68,7 @@ func Orchestrator() {
 		fs.StringVar(&cliFlags.Streamer.InputFile, "streamer-input-file", "bbb_sunflower_1080p_30fps_2sGOP_noBframes_2min.mp4", "Input file to stream")
 
 		fs.StringVar(&cliFlags.Playback.BaseURL, "playback-base-url", "https://monster.lvpr.tv/", "Base URL for the player page")
+		fs.StringVar(&cliFlags.Playback.ManifestURL, "playback-manifest-url", "", "URL for playback")
 		utils.JSONVarFlag(fs, &cliFlags.Playback.RegionViewersJSON, "playback-region-viewers-json", `{"us-central1":100,"europe-west2":100}`, "JSON object of Google Cloud regions to the number of viewers that should be simulated there. Notice that the values must be multiples of playback-viewers-per-worker, and up to 1000 x that")
 		fs.IntVar(&cliFlags.Playback.ViewersPerWorker, "playback-viewers-per-worker", 50, "Number of viewers to simulate per worker")
 		fs.IntVar(&cliFlags.Playback.MemoryPerViewerMiB, "playback-memory-per-viewer-mib", 100, "Amount of memory to allocate per viewer (browser tab)")
@@ -138,7 +140,7 @@ func runLoadTest(ctx context.Context, args loadTestArguments) error {
 	}
 
 	glog.Infof("Stream created: %s", stream.ID)
-	glog.Infof("Access the stream at: %s", path.Join(args.APIServer, "/dashboard/streams", stream.ID))
+	glog.Infof("Access the stream at: https://%s", path.Join(args.APIServer, "/dashboard/streams", stream.ID))
 
 	_, streamer, err := gcloud.CreateJob(ctx, streamerJobSpec(args, stream.StreamKey))
 	if err != nil {
@@ -269,6 +271,11 @@ func playerJobSpec(args loadTestArguments, region string, viewers int, playbackI
 	numTasks := viewers / args.Playback.ViewersPerWorker
 	timeout := args.TestDuration + 10*time.Minute
 
+	playbackURL := ""
+	if args.Playback.ManifestURL != "" {
+		playbackURL = fmt.Sprintf(args.Playback.ManifestURL, playbackID)
+	}
+
 	return gcloud.JobSpec{
 		Region: region,
 
@@ -277,8 +284,7 @@ func playerJobSpec(args loadTestArguments, region string, viewers int, playbackI
 		Args: []string{
 			"-base-url", args.Playback.BaseURL,
 			"-playback-id", playbackID,
-			// TODO: Support region/node-specific playback by building the playback URL here
-			// "-playback-url", stream.PlaybackURL,
+			"-playback-url", playbackURL,
 			"-simultaneous", strconv.Itoa(simultaneous),
 			"-duration", args.TestDuration.String(),
 		},