client.go

package main

import (
	"bytes"
	"flag"
	"math"
	"net/http"
	"time"
)

var oscillationPeriod = flag.Duration("oscillation-period", time.Hour, "The duration of the rate oscillation period.")

func startClient(servAddr string) {

	oscillationFactor := func() float64 {
		return 2 + math.Sin(math.Sin(2*math.Pi*float64(time.Since(start))/float64(*oscillationPeriod)))
	}

	ignoreRequest := func(resp *http.Response, err error) {
		if err != nil {
			return
		}
		resp.Body.Close()
	}

	// GET /api/foo.
	go func() {
		for {
			ignoreRequest(http.Get("http://" + servAddr + "/api/foo"))
			time.Sleep(time.Duration(10*oscillationFactor()) * time.Millisecond)
		}
	}()
	// POST /api/foo.
	go func() {
		for {
			ignoreRequest(http.Post("http://"+servAddr+"/api/foo", "text/plain", &bytes.Buffer{}))
			time.Sleep(time.Duration(150*oscillationFactor()) * time.Millisecond)
		}
	}()
	// GET /api/bar.
	go func() {
		for {
			ignoreRequest(http.Get("http://" + servAddr + "/api/bar"))
			time.Sleep(time.Duration(20*oscillationFactor()) * time.Millisecond)
		}
	}()
	// POST /api/bar.
	go func() {
		for {
			ignoreRequest(http.Post("http://"+servAddr+"/api/bar", "text/plain", &bytes.Buffer{}))
			time.Sleep(time.Duration(100*oscillationFactor()) * time.Millisecond)
		}
	}()
	// GET /api/nonexistent.
	go func() {
		for {
			ignoreRequest(http.Get("http://" + servAddr + "/api/nonexistent"))
			time.Sleep(time.Duration(500*oscillationFactor()) * time.Millisecond)
		}
	}()
}