package testing

import "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing"

Index ¶

• func NewNoRestraintFactory() fq.QueueSetFactory
• type Integrator
• func NewIntegrator(clk clock.PassiveClock) Integrator
• type IntegratorResults

Functions ¶

func NewNoRestraintFactory ¶

func NewNoRestraintFactory() fq.QueueSetFactory

NewNoRestraintFactory makes a QueueSetFactory that produces QueueSets that exert no restraint --- every request is dispatched for execution as soon as it arrives.

Types ¶

type Integrator ¶

type Integrator interface {
	Set(float64) // set the value of X
	Add(float64) // add the given quantity to X
	GetResults() IntegratorResults
}

Integrator computes the integral of some variable X over time as read from a particular clock. The integral starts when the Integrator is created, and ends at the latest operation on the Integrator.

func NewIntegrator ¶

func NewIntegrator(clk clock.PassiveClock) Integrator

NewIntegrator makes one that uses the given clock

type IntegratorResults ¶

type IntegratorResults struct {
	Duration  float64 //seconds
	Average   float64
	Deviation float64 //sqrt(avg((value-avg)^2))
}

IntegratorResults holds statistical abstracts of the integration

Source Files ¶

integrator.go no-restraint.go

Directories ¶