func (l *Load) startWorkers(count int, maxQps bool) {
	for i := 0; i < count; i++ {
		go func() {
			client := GetQuiverClient(l.server)
			var diff *gen.HFileServiceClient
			if l.diffing {
				diff = GetQuiverClient(l.diff)
			}
			for {
				if !maxQps {
					<-l.work
				}
				l.sendOne(client, diff)
			}
		}()
	}
}
starts count worker processes, each with their own thttp client(s), watching the work chan.
package main
import (
	"encoding/hex"
	"log"
	"math/rand"
	"reflect"
	"sort"
	"sync"
	"time"
	"github.com/foursquare/fsgo/report"
	"github.com/foursquare/quiver/gen"
	"github.com/foursquare/quiver/util"
)
func renderErr(raw error) string {
	msg := raw.Error()
	switch e := raw.(type) {
	case *gen.HFileServiceException:
		msg = e.GetMessage()
	default:
	}
	return msg
}