scheduler

Apr 24, 2023

Changes in this version

type Scheduler

+ Revert func(tokens uint64)

type WFQScheduler

+ func (sched *WFQScheduler) Revert(tokens uint64)

Apr 17, 2023

Changes in this version

+ type BasicTokenBucket struct

+ func NewBasicTokenBucket(now time.Time, fillRate float64, metrics *TokenBucketMetrics) *BasicTokenBucket

+ func (btb *BasicTokenBucket) GetFillRate() float64

+ func (btb *BasicTokenBucket) PassThrough() bool

+ func (btb *BasicTokenBucket) PreprocessRequest(now time.Time, rContext Request) bool

+ func (btb *BasicTokenBucket) Return(tokens float64)

+ func (btb *BasicTokenBucket) SetFillRate(now time.Time, fillRate float64)

+ func (btb *BasicTokenBucket) SetPassThrough(passThrough bool)

+ func (btb *BasicTokenBucket) Take(now time.Time, tokens float64) (time.Duration, bool)

+ func (btb *BasicTokenBucket) TakeIfAvailable(now time.Time, tokens float64) bool

+ type Request struct

+ FairnessLabel string

+ Priority uint8

+ Tokens uint64

+ type Scheduler interface

+ Schedule func(ctx context.Context, request Request) bool

+ func NewWFQScheduler(tokenManger TokenManager, clk clockwork.Clock, metrics *WFQMetrics) Scheduler

+ type TokenBucketLoadMultiplier struct

+ func NewTokenBucketLoadMultiplier(now time.Time, slotCount uint8, slotDuration time.Duration, ...) *TokenBucketLoadMultiplier

+ func (tbls *TokenBucketLoadMultiplier) LoadMultiplier() float64

+ func (tbls *TokenBucketLoadMultiplier) PassThrough() bool

+ func (tbls *TokenBucketLoadMultiplier) PreprocessRequest(now time.Time, rContext Request) bool

+ func (tbls *TokenBucketLoadMultiplier) Return(tokens float64)

+ func (tbls *TokenBucketLoadMultiplier) SetContinuousTracking(continuousTracking bool)

+ func (tbls *TokenBucketLoadMultiplier) SetLoadMultiplier(now time.Time, lm float64)

+ func (tbls *TokenBucketLoadMultiplier) SetPassThrough(passThrough bool)

+ func (tbls *TokenBucketLoadMultiplier) Take(now time.Time, tokens float64) (time.Duration, bool)

+ func (tbls *TokenBucketLoadMultiplier) TakeIfAvailable(now time.Time, tokens float64) bool

+ type TokenBucketLoadMultiplierMetrics struct

+ LMGauge prometheus.Gauge

+ TokenBucketMetrics *TokenBucketMetrics

+ type TokenBucketMetrics struct

+ AvailableTokensGauge prometheus.Gauge

+ BucketCapacityGauge prometheus.Gauge

+ FillRateGauge prometheus.Gauge

+ type TokenManager interface

+ PreprocessRequest func(now time.Time, request Request) bool

+ Return func(tokens float64)

+ Take func(now time.Time, tokens float64) (time.Duration, bool)

+ TakeIfAvailable func(now time.Time, tokens float64) bool

+ type WFQMetrics struct

+ FlowsGauge prometheus.Gauge

+ HeapRequestsGauge prometheus.Gauge

+ type WFQScheduler struct

+ func (sched *WFQScheduler) GetPendingFlows() int

+ func (sched *WFQScheduler) GetPendingRequests() int

+ func (sched *WFQScheduler) Schedule(ctx context.Context, request Request) bool

+ type WindowedCounter struct

+ func NewWindowedCounter(now time.Time, totalSlots uint8, slotDuration time.Duration) *WindowedCounter

+ func (counter *WindowedCounter) AddTokens(now time.Time, tokens uint64) bool

+ func (counter *WindowedCounter) CalculateTokenRate() float64

+ func (counter *WindowedCounter) IsBootstrapping() bool