kubernetes/staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go

const retryAfter …

const inflightUsageMetricUpdatePeriod …

var nonMutatingRequestVerbs …

var watchVerbs …

func handleError(w http.ResponseWriter, r *http.Request, err error) { … }

type requestWatermark …

func (w *requestWatermark) recordMutating(mutatingVal int) { … }

func (w *requestWatermark) recordReadOnly(readOnlyVal int) { … }

var watermark …

// startWatermarkMaintenance starts the goroutines to observe and maintain the specified watermark.
func startWatermarkMaintenance(watermark *requestWatermark, stopCh <-chan struct{ … }

var initMaxInFlightOnce …

func initMaxInFlight(nonMutatingLimit, mutatingLimit int) { … }

// WithMaxInFlightLimit limits the number of in-flight requests to buffer size of the passed in channel.
func WithMaxInFlightLimit(
	handler http.Handler,
	nonMutatingLimit int,
	mutatingLimit int,
	longRunningRequestCheck apirequest.LongRunningRequestCheck,
) http.Handler { … }

// StartMaxInFlightWatermarkMaintenance starts the goroutines to observe and maintain watermarks for max-in-flight
// requests.
func StartMaxInFlightWatermarkMaintenance(stopCh <-chan struct{ … }