Function runConstantRequestsPerSecond

dev/load.go:108–135

(url string, jsonBytes []byte)

}

func runConstantRequestsPerSecond(url string, jsonBytes []byte) {
	inFlightCount := Counter{}
	ticker := time.NewTicker(_requestInterval)
	done := make(chan bool)

	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt, syscall.SIGTERM)
	go func() {
		<-c
		done <- true
	}()

	start := time.Now()

FOR_LOOP:
	for {
		select {
		case <-done:
			break FOR_LOOP
		case <-ticker.C:
			go runConstantRequestsPerSecondIteration(url, jsonBytes, &inFlightCount, done)
		}
	}

	elapsed := time.Since(start)
	requestRate := float64(_requestCount.Load()) / elapsed.Seconds()
	fmt.Printf("\nelapsed time: %s | %d requests @ %f req/s | %d succeeded | %d http errors | %d go errors\n", elapsed, _requestCount.Load(), requestRate, _successCount.Load(), _httpErrCount.Load(), _goErrCount.Load())
}

func runConstantRequestsPerSecondIteration(url string, jsonBytes []byte, inFlightCount *Counter, done chan bool) {
	if _maxInFlight > 0 {