kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/integrator.go

type Integrator …

type IntegratorResults …

// Equal tests for semantic equality.
// This considers all NaN values to be equal to each other.
func (x *IntegratorResults) Equal(y *IntegratorResults) bool { … }

type integrator …

// NewNamedIntegrator makes one that uses the given clock and name
func NewNamedIntegrator(clock clock.PassiveClock, name string) Integrator { … }

func (igr *integrator) Set(x float64) { … }

func (igr *integrator) Add(deltaX float64) { … }

func (igr *integrator) Inc() { … }

func (igr *integrator) Dec() { … }

func (igr *integrator) SetToCurrentTime() { … }

func (igr *integrator) setLocked(x float64) { … }

func (igr *integrator) updateLocked() { … }

func (igr *integrator) GetResults() IntegratorResults { … }

func (igr *integrator) Reset() IntegratorResults { … }

func (igr *integrator) getResultsLocked() (results IntegratorResults) { … }

type Moments …

// ConstantMoments is for a constant X
func ConstantMoments(dt, x float64) Moments { … }

// Add combines over two ranges of time
func (igr Moments) Add(ogr Moments) Moments { … }

// Sub finds the difference between a range of time and a subrange
func (igr Moments) Sub(ogr Moments) Moments { … }

// AvgAndStdDev returns the average and standard devation
func (igr Moments) AvgAndStdDev() (float64, float64) { … }