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

type RequestWaitGroup …

// WithWaitGroup adds all non long-running requests to wait group, which is used for graceful shutdown.
func WithWaitGroup(handler http.Handler, longRunning apirequest.LongRunningRequestCheck, wg RequestWaitGroup) http.Handler { … }

func withWaitGroup(handler http.Handler, longRunning apirequest.LongRunningRequestCheck, wg RequestWaitGroup, isRequestExemptFn isRequestExemptFunc) http.Handler { … }

func waitGroupWriteRetryAfterToResponse(w http.ResponseWriter) { … }