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

type request …

type completedWorkEstimate …

type queue …

type queueSum …

func (req *request) totalWork() fcrequest.SeatSeconds { … }

func (qs *queueSet) completeWorkEstimate(we *fcrequest.WorkEstimate) completedWorkEstimate { … }

func (qs *queueSet) computeInitialWork(we *fcrequest.WorkEstimate) fcrequest.SeatSeconds { … }

func (qs *queueSet) computeFinalWork(we *fcrequest.WorkEstimate) fcrequest.SeatSeconds { … }

func (q *queue) dumpLocked(includeDetails bool) debug.QueueDump { … }

func dumpRequest(includeDetails bool) func(*request) debug.RequestDump { … }

// SetMapReduce is map-reduce starting from a set type in the sets package.
func SetMapReduce[Elt comparable, Result, Accumulator any](mapFn func(Elt) Result, reduceFn func(Accumulator, Result) Accumulator) func(map[Elt]sets.Empty) Accumulator { … }

// SliceMapReduce is map-reduce starting from a slice.
func SliceMapReduce[Elt, Result, Accumulator any](mapFn func(Elt) Result, reduceFn func(Accumulator, Result) Accumulator) func([]Elt) Accumulator { … }

func or(x, y bool) bool { … }

func append1[Elt any](slice []Elt, next Elt) []Elt { … }