- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for withWaitGroup (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/waitgroup.go
Add(delta int) error // Done decrements the WaitGroup counter. Done() } // 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 { // NOTE: both WithWaitGroup and WithRetryAfter must use the same exact isRequestExemptFunc 'isRequestExemptFromRetryAfter,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 10 21:18:55 UTC 2023 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/with_retry_after.go
// // TODO: is there a way to merge WithWaitGroup and this filter? func WithRetryAfter(handler http.Handler, shutdownDelayDurationElapsedCh <-chan struct{}) http.Handler { shutdownRetryAfterParams := &retryAfterParams{ TearDownConnection: true, Message: "The apiserver is shutting down, please try again later.", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 31 14:10:46 UTC 2021 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/with_retry_after_test.go
if test.safeWaitGroupIsWaiting { // mark the safe wait group as waiting, it's a blocking call // but since the WaitGroup counter is zero it should not block safeWG.Wait() } wrapped := WithWaitGroup(handler, func(*http.Request, *apirequest.RequestInfo) bool { return false }, safeWG) wrapped = WithRetryAfter(wrapped, test.shutdownDelayDurationElapsedFn())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 31 14:10:46 UTC 2021 - 6.1K bytes - Viewed (0)