Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for withWaitGroup (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top