Function executeScenario

ring/batch_test.go:61–80

(bt batchTracker, scenarios []scenario)

}

func executeScenario(bt batchTracker, scenarios []scenario) error {
	var wg sync.WaitGroup
	wg.Add(len(scenarios))

	go func() {
		for _, sc := range scenarios {
			bt.record(sc.itemTrackers, sc.err, isHTTPStatus4xx)
			wg.Done()
		}
	}()

	wg.Wait()

	select {
	case err := <-bt.err:
		return err
	case <-bt.done:
		return nil
	}
}