Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newLifecycleSignals (0.28 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go

    func (s lifecycleSignals) ShuttingDown() <-chan struct{} {
    	return s.NotAcceptingNewRequest.Signaled()
    }
    
    // newLifecycleSignals returns an instance of lifecycleSignals interface to be used
    // to coordinate lifecycle of the apiserver
    func newLifecycleSignals() lifecycleSignals {
    	return lifecycleSignals{
    		ShutdownInitiated:          newNamedChannelWrapper("ShutdownInitiated"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:30 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/config_test.go

    		RequestTimeout:                 10 * time.Second,
    		LongRunningFunc:                func(_ *http.Request, _ *request.RequestInfo) bool { return false },
    		lifecycleSignals:               newLifecycleSignals(),
    		TracerProvider:                 tracing.NewNoopTracerProvider(),
    	}
    
    	h := DefaultBuildHandlerChain(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// confirm this is a no-op
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/config.go

    		}
    
    		hash := sha256.Sum256(hashData)
    		id = "apiserver-" + strings.ToLower(base32.StdEncoding.WithPadding(base32.NoPadding).EncodeToString(hash[:16]))
    	}
    	lifecycleSignals := newLifecycleSignals()
    
    	return &Config{
    		Serializer:                     codecs,
    		BuildHandlerChainFunc:          DefaultBuildHandlerChain,
    		NonLongRunningRequestWaitGroup: new(utilwaitgroup.SafeWaitGroup),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
Back to top