func init()

in step2/src/loadgen/config.go [46:88]

• 43 lines of code
• 11 McCabe index (conditional complexity)

func init() {
	clientSvcAddr := defaultClientSvcAddr
	if os.Getenv("CLIENT_SVC_ADDR") != "" {
		clientSvcAddr = os.Getenv("CLIENT_SVC_ADDR")
	}
	var err error
	reqURL, err = url.Parse(fmt.Sprintf("http://" + clientSvcAddr))
	if err != nil {
		log.Fatalf("failed to build request URL for %v: %v", clientSvcAddr, err)
	}
	numWorkers = defaultWorkers
	if os.Getenv("NUM_WORKERS") != "" {
		w, err := strconv.ParseInt(os.Getenv("NUM_WORKERS"), 10, 64)
		if err != nil {
			log.Fatalf("failed to parse NUM_WORKERS: %v", err)
		}
		numWorkers = int(w)
	}
	numConcurrency = defaultConcurrency
	if os.Getenv("NUM_CONCURRENCY") != "" {
		c, err := strconv.ParseInt(os.Getenv("NUM_CONCURRENCY"), 10, 64)
		if err != nil {
			log.Fatalf("failed to parse NUM_CONCURRENCY: %v", err)
		}
		numConcurrency = int(c)
	}
	numRounds = defaultRounds
	if os.Getenv("NUM_ROUNDS") != "" {
		r, err := strconv.ParseInt(os.Getenv("NUM_ROUNDS"), 10, 64)
		if err != nil {
			log.Fatalf("failed to parse NUM_ROUNDS: %v", err)
		}
		numRounds = int(r)
	}
	intervalMs = defaultIntervalMs
	if os.Getenv("INTERVAL_MS") != "" {
		i, err := strconv.ParseInt(os.Getenv("INTERVAL_MS"), 10, 64)
		if err != nil {
			log.Fatalf("failed to parse INTERVAL_MS: %v", err)
		}
		intervalMs = int(i)
	}
}