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{}