Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WithServerShutdownSignal (0.35 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/request/server_shutdown_signal.go

    func ServerShutdownSignalFrom(ctx context.Context) ServerShutdownSignal {
    	ev, _ := ctx.Value(serverShutdownSignalKey).(ServerShutdownSignal)
    	return ev
    }
    
    // WithServerShutdownSignal returns a new context that stores
    // the ServerShutdownSignal interface instance.
    func WithServerShutdownSignal(parent context.Context, window ServerShutdownSignal) context.Context {
    	if ServerShutdownSignalFrom(parent) != nil {
    		return parent // Avoid double registering.
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:30 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination.go

    			return
    		}
    
    		// attach ServerShutdownSignal to the watch request so that the
    		// watch handler loop can return as soon as the server signals
    		// that it is shutting down.
    		ctx = apirequest.WithServerShutdownSignal(req.Context(), termination)
    		req = req.WithContext(ctx)
    
    		defer wg.Done()
    		handler.ServeHTTP(w, req)
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:49 UTC 2023
    - 2K bytes
    - Viewed (0)
Back to top