- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for shuttingDown (0.17 sec)
-
pilot/pkg/xds/discovery.go
// This limits the number of pushes that can happen concurrently semaphore <- struct{}{} // Get the next proxy to push. This will block if there are no updates required. client, push, shuttingdown := queue.Dequeue() if shuttingdown { return } recordPushTriggers(push.Reason) // Signals that a push is done by reading from the semaphore, allowing another send on it. doneFunc := func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
// this simulates a watch well enough for our test signals := apirequest.ServerShutdownSignalFrom(req.Context()) if signals == nil { w.WriteHeader(http.StatusInternalServerError) return } <-signals.ShuttingDown() w.WriteHeader(http.StatusOK) }) s.Handler.NonGoRestfulMux.Handle("/apis/watches.group/v1/namespaces/foo/bar", handler) return inflight }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0)