func fairAlloc(demands []float64, capacity float64) []float64 { … }
func TestFairAlloc(t *testing.T) { … }
type uniformClient …
func newUniformClient(hash uint64, nThreads, nCalls int, execDuration, thinkDuration time.Duration) uniformClient { … }
func (uc uniformClient) setSplit() uniformClient { … }
func (uc uniformClient) setInitWidth(seats uint64) uniformClient { … }
func (uc uniformClient) pad(finalSeats int, duration time.Duration) uniformClient { … }
type uniformScenario …
func (us uniformScenario) exercise(t *testing.T) { … }
type uniformScenarioState …
func (uss *uniformScenarioState) exercise() { … }
type uniformScenarioThread …
func (ust *uniformScenarioThread) start() { … }
func (ust *uniformScenarioThread) genCallK(k int) func(time.Time) { … }
func (ust *uniformScenarioThread) callK(k int) { … }
func insistRequestFromUser(t *testing.T, qs fq.QueueSet, username string) { … }
func (uss *uniformScenarioState) evalTo(lim time.Time, last, expectFair bool, margin float64) { … }
func (uss *uniformScenarioState) finalReview() { … }
func TestMain(m *testing.M) { … }
func TestNoRestraint(t *testing.T) { … }
func TestBaseline(t *testing.T) { … }
func TestExampt(t *testing.T) { … }
func TestSeparations(t *testing.T) { … }
func TestUniformFlowsHandSize1(t *testing.T) { … }
func TestUniformFlowsHandSize3(t *testing.T) { … }
func TestDifferentFlowsExpectEqual(t *testing.T) { … }
func TestSeatSecondsRollover(t *testing.T) { … }
func TestDifferentFlowsExpectUnequal(t *testing.T) { … }
func TestDifferentWidths(t *testing.T) { … }
func TestTooWide(t *testing.T) { … }
func TestWindup(t *testing.T) { … }
func TestDifferentFlowsWithoutQueuing(t *testing.T) { … }
func TestContextCancel(t *testing.T) { … }
func countingPromiseFactoryFactory(activeCounter counter.GoRoutineCounter) promiseFactoryFactory { … }
func TestTotalRequestsExecutingWithPanic(t *testing.T) { … }
func TestFindDispatchQueueLocked(t *testing.T) { … }
func TestFinishRequestLocked(t *testing.T) { … }
func TestRequestSeats(t *testing.T) { … }
func TestRequestWork(t *testing.T) { … }
func newFIFO(requests ...*request) fifo { … }
func newGaugePair(clk clock.PassiveClock) metrics.RatioedGaugePair { … }
func newExecSeatsGauge(clk clock.PassiveClock) metrics.RatioedGauge { … }
func float64close(x, y float64) bool { … }
func uint64max(a, b uint64) uint64 { … }
func float64NaNTo0(x float64) float64 { … }
func qsComplete(qsc fq.QueueSetCompleter, concurrencyLimit int) fq.QueueSet { … }